Interface SinkQueueWithCancel<T>

  • All Superinterfaces:
    SinkQueue<T>

    public interface SinkQueueWithCancel<T>
    extends SinkQueue<T>
    This trait adds cancel support to SinkQueue.
    • Method Detail

      • cancel

        void cancel()
        Cancels the stream. This method returns right away without waiting for actual finalizing the stream.