Package org.reactivestreams
Class FlowAdapters.ReactiveToFlowSubscription
java.lang.Object
org.reactivestreams.FlowAdapters.ReactiveToFlowSubscription
- All Implemented Interfaces:
Subscription
- Enclosing class:
FlowAdapters
Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
flow
-
-
Constructor Details
-
ReactiveToFlowSubscription
-
-
Method Details
-
request
public void request(long n) Description copied from interface:Subscription
No events will be sent by aPublisher
until demand is signaled via this method.It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the
Publisher
as "effectively unbounded".Whatever has been requested can be sent by the
Publisher
so only signal demand for what can be safely handled.A
Publisher
can send less than is requested if the stream ends but then must emit eitherSubscriber.onError(Throwable)
orSubscriber.onComplete()
.- Specified by:
request
in interfaceSubscription
- Parameters:
n
- the strictly positive number of elements to requests to the upstreamPublisher
-
cancel
public void cancel()Description copied from interface:Subscription
Request thePublisher
to stop sending data and clean up resources.Data may still be sent to meet previously signalled demand after calling cancel.
- Specified by:
cancel
in interfaceSubscription
-