Package org.apache.pekko.stream.javadsl

Interface SinkQueueWithCancel<T>

All Superinterfaces:
SinkQueue<T>
public interface SinkQueueWithCancel<T> extends SinkQueue<T>
This trait adds cancel support to SinkQueue.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cancel()
    Cancels the stream.

    Methods inherited from interface org.apache.pekko.stream.javadsl.SinkQueue

    pull

  • Method Details

    • cancel

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