public static final class ZipAction.InnerSubscriber<O,V> extends FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>
Modifier and Type | Method and Description |
---|---|
long |
getCapacity()
Return defined element capacity, used to drive new
Subscription
request needs. |
boolean |
isReactivePull(Dispatcher dispatcher,
long producerCapacity)
Get the assigned
Dispatcher . |
void |
onComplete() |
void |
onNext(O ev) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
void |
request(long n) |
String |
toString() |
accept, cancel, onError
public void onSubscribe(org.reactivestreams.Subscription subscription)
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<O>
onComplete
in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>
public void request(long n)
request
in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>
public void onNext(O ev)
public boolean isReactivePull(Dispatcher dispatcher, long producerCapacity)
NonBlocking
Dispatcher
.isReactivePull
in interface NonBlocking
isReactivePull
in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>
public long getCapacity()
NonBlocking
Subscription
request needs. This is the maximum in-flight data allowed to transit to this elements.getCapacity
in interface NonBlocking
getCapacity
in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>
public String toString()
toString
in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>
Copyright © 2016. All rights reserved.