public static final class MergeAction.InnerSubscriber<I> extends FanInAction.InnerSubscriber<I,I,I>
Modifier and Type | Method and Description |
---|---|
boolean |
isReactivePull(Dispatcher dispatcher,
long producerCapacity)
Get the assigned
Dispatcher . |
void |
onNext(I ev) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
String |
toString() |
accept, cancel, getCapacity, onComplete, onError, request
public void onSubscribe(org.reactivestreams.Subscription subscription)
public void onNext(I ev)
public boolean isReactivePull(Dispatcher dispatcher, long producerCapacity)
NonBlocking
Dispatcher
.isReactivePull
in interface NonBlocking
isReactivePull
in class FanInAction.InnerSubscriber<I,I,I>
Copyright © 2017. All rights reserved.