public interface Control
Stream
terminal action such as
Stream.consume(reactor.fn.Consumer)
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Stop consuming signals from upstream.
|
StreamUtils.StreamVisitor |
debug()
Parse the materialized upstream source to fetch a materialized map form which allows for graph-style printing.
|
boolean |
isPublishing()
Check if the current stream is emitting any signal.
|
void |
requestAll()
Usually requests Long.MAX_VALUE, which instructs a stream to never end until completed or cancelled.
|
void |
requestMore(long n)
Request the next n elements from the source
|
void requestMore(long n)
n
- the number of elements to requestvoid requestAll()
void cancel()
PushSubscription.terminated
flag.boolean isPublishing()
StreamUtils.StreamVisitor debug()
StreamUtils.StreamVisitor
a Debug container for the current sourceCopyright © 2017. All rights reserved.