akka.stream.scaladsl

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 and Description
void	cancel() Cancel the stream.

Methods inherited from interface akka.stream.scaladsl.SinkQueue

pull

Method Detail

cancel

void cancel()

Cancel the stream. This method returns right away without waiting for actual finalizing stream.