public static class FanInSubscription.InnerSubscription<O,E,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,?>> extends Object implements org.reactivestreams.Subscription
Constructor and Description |
---|
InnerSubscription(org.reactivestreams.Subscription wrapped,
SUBSCRIBER subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
org.reactivestreams.Subscription |
getDelegate() |
void |
request(long n) |
public InnerSubscription(org.reactivestreams.Subscription wrapped, SUBSCRIBER subscriber)
Copyright © 2016. All rights reserved.