public class FanInSubscription<O,E,X,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,X>> extends ReactiveSubscription<E> implements org.reactivestreams.Subscriber<E>
Modifier and Type | Class and Description |
---|---|
static class |
FanInSubscription.InnerSubscription<O,E,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,?>> |
Modifier and Type | Field and Description |
---|---|
protected int |
leftIndex |
protected SerializedSubscriber<E> |
serializer |
protected reactor.rx.action.combination.FanInSubscription.FastList |
subscriptions |
protected boolean |
terminated |
buffer, currentNextSignals, draining, maxCapacity
PENDING_UPDATER, pendingRequestSignals, publisher, subscriber, TERMINAL_UPDATER
Constructor and Description |
---|
FanInSubscription(org.reactivestreams.Subscriber<? super E> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
forEach(Consumer<FanInSubscription.InnerSubscription<O,E,SUBSCRIBER>> consumer) |
protected void |
onRequest(long elements) |
void |
onSubscribe(org.reactivestreams.Subscription s) |
protected void |
parallelRequest(long elements) |
protected FanInSubscription.InnerSubscription<O,E,SUBSCRIBER> |
peek() |
void |
serialComplete() |
void |
serialError(Throwable t) |
void |
serialNext(E next) |
protected FanInSubscription.InnerSubscription<O,E,SUBSCRIBER> |
shift(int sequenceId) |
String |
toString() |
capacity, currentNextSignals, getBuffer, getBufferSize, isComplete, maxCapacity, onComplete, onNext, request, shouldRequestPendingSignals, updatePendingRequests
accept, equals, getPublisher, getSubscriber, hashCode, hasPublisher, markAsDeferredStart, markAsStarted, onError, pendingRequestSignals, start, terminate, wrap
protected final reactor.rx.action.combination.FanInSubscription.FastList subscriptions
protected final SerializedSubscriber<E> serializer
protected volatile boolean terminated
protected int leftIndex
public FanInSubscription(org.reactivestreams.Subscriber<? super E> subscriber)
protected void onRequest(long elements)
onRequest
in class PushSubscription<E>
protected void parallelRequest(long elements)
public void forEach(Consumer<FanInSubscription.InnerSubscription<O,E,SUBSCRIBER>> consumer)
public void cancel()
cancel
in interface org.reactivestreams.Subscription
cancel
in class PushSubscription<E>
protected FanInSubscription.InnerSubscription<O,E,SUBSCRIBER> shift(int sequenceId)
protected FanInSubscription.InnerSubscription<O,E,SUBSCRIBER> peek()
public void onSubscribe(org.reactivestreams.Subscription s)
onSubscribe
in interface org.reactivestreams.Subscriber<E>
public void serialNext(E next)
public void serialError(Throwable t)
public void serialComplete()
public String toString()
toString
in class ReactiveSubscription<E>
Copyright © 2016. All rights reserved.