akka.stream.javadsl

Interface SourceQueueWithComplete<T>

All Superinterfaces:

SourceQueue<T>

All Known Implementing Classes:

SourceQueueAdapter

public interface SourceQueueWithComplete<T>
extends SourceQueue<T>

This trait adds completion support to SourceQueue.

Method Summary

Modifier and Type	Method and Description
void	complete() Complete the stream normally.
void	fail(java.lang.Throwable ex) Complete the stream with a failure.

Methods inherited from interface akka.stream.javadsl.SourceQueue

offer, watchCompletion

Method Detail

complete

void complete()

Complete the stream normally. Use watchCompletion to be notified of this operation&rsquo;s success.

fail

void fail(java.lang.Throwable ex)

Complete the stream with a failure. Use watchCompletion to be notified of this operation&rsquo;s success.

Parameters:

ex - (undocumented)