public class FanOutSubscription<O> extends PushSubscription<O>
PENDING_UPDATER, pendingRequestSignals, publisher, subscriber, TERMINAL_UPDATER, terminated
Constructor and Description |
---|
FanOutSubscription(Stream<O> publisher,
PushSubscription<O> reactiveSubscriptionA,
PushSubscription<O> reactiveSubscriptionB) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(PushSubscription<O> subscription) |
void |
cancel() |
boolean |
contains(PushSubscription<O> subscription) |
void |
forEach(Consumer<PushSubscription<O>> consumer) |
List<PushSubscription<O>> |
getSubscriptions() |
boolean |
isComplete() |
boolean |
isEmpty() |
void |
onComplete() |
void |
onError(Throwable ev) |
void |
onNext(O ev) |
boolean |
remove(PushSubscription<O> subscription) |
void |
start() |
accept, equals, getPublisher, getSubscriber, hashCode, hasPublisher, markAsDeferredStart, markAsStarted, maxCapacity, onRequest, pendingRequestSignals, request, shouldRequestPendingSignals, terminate, toString, updatePendingRequests, wrap
public FanOutSubscription(Stream<O> publisher, PushSubscription<O> reactiveSubscriptionA, PushSubscription<O> reactiveSubscriptionB)
public void onComplete()
onComplete
in class PushSubscription<O>
public void onNext(O ev)
onNext
in class PushSubscription<O>
public void start()
start
in class PushSubscription<O>
public void cancel()
cancel
in interface org.reactivestreams.Subscription
cancel
in class PushSubscription<O>
public void onError(Throwable ev)
onError
in class PushSubscription<O>
public boolean isComplete()
isComplete
in class PushSubscription<O>
public void forEach(Consumer<PushSubscription<O>> consumer)
public List<PushSubscription<O>> getSubscriptions()
public boolean isEmpty()
public boolean remove(PushSubscription<O> subscription)
public boolean add(PushSubscription<O> subscription)
public boolean contains(PushSubscription<O> subscription)
Copyright © 2016. All rights reserved.