public interface SourceQueueWithComplete<T> extends SourceQueue<T>
SourceQueue
.Modifier and Type | Method and Description |
---|---|
void |
complete()
Complete the stream normally.
|
void |
fail(java.lang.Throwable ex)
Complete the stream with a failure.
|
offer, watchCompletion
void complete()
watchCompletion
to be notified of this
operation’s success.void fail(java.lang.Throwable ex)
watchCompletion
to be notified of this
operation’s success.ex
- (undocumented)