Package org.reactivestreams
Class FlowAdapters.FlowToReactiveSubscription
java.lang.Object
org.reactivestreams.FlowAdapters.FlowToReactiveSubscription
- All Implemented Interfaces:
Flow.Subscription
- Enclosing class:
FlowAdapters
static final class FlowAdapters.FlowToReactiveSubscription
extends Object
implements Flow.Subscription
Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
reactiveStreams
-
-
Constructor Details
-
FlowToReactiveSubscription
-
-
Method Details
-
request
public void request(long n) - Specified by:
request
in interfaceFlow.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceFlow.Subscription
-