akka.stream.javadsl

Interface SinkQueueWithCancel<T>

All Superinterfaces:

SinkQueue<T>

All Known Implementing Classes:

SinkQueueAdapter

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.javadsl.SinkQueue

pull

Method Detail

cancel

void cancel()

Cancel the stream.