Constructor and Description |
---|
TapAndControls(Tap<? extends O> tap,
Control controls) |
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.
|
O |
get()
Get an object.
|
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
|
public void requestAll()
Control
requestAll
in interface Control
public void cancel()
Control
PushSubscription.terminated
flag.public boolean isPublishing()
Control
isPublishing
in interface Control
public void requestMore(long n)
Control
requestMore
in interface Control
n
- the number of elements to requestpublic StreamUtils.StreamVisitor debug()
Control
debug
in interface Control
StreamUtils.StreamVisitor
a Debug container for the current sourceCopyright © 2016. All rights reserved.