Package org.apache.pekko.stream.scaladsl

Interface SinkQueueWithCancel<T>

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

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static final class 
    SinkQueueWithCancel.QueueOps<T>
     
    static class 
    SinkQueueWithCancel.QueueOps$
     

  • Method Summary

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

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

    pull

  • Method Details

    • cancel

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