Package | Description |
---|---|
reactor.core.reactivestreams |
Modifier and Type | Field and Description |
---|---|
protected static AtomicLongFieldUpdater<SubscriptionWithContext> |
SubscriptionWithContext.PENDING_UPDATER |
protected static AtomicIntegerFieldUpdater<SubscriptionWithContext> |
SubscriptionWithContext.TERMINATED_UPDATER |
Modifier and Type | Method and Description |
---|---|
static <C> SubscriptionWithContext<C> |
SubscriptionWithContext.create(org.reactivestreams.Subscription subscription,
C context)
Attach a given arbitrary context (stateful information) to a
Subscription , all Subscription methods
will delegate properly. |
Modifier and Type | Method and Description |
---|---|
static <T,C> org.reactivestreams.Subscriber<T> |
SubscriberFactory.create(Function<org.reactivestreams.Subscription,C> subscriptionHandler,
BiConsumer<T,SubscriptionWithContext<C>> dataConsumer)
Create a
Subscriber reacting onSubscribe and onNext, eventually sharing a context. |
static <T,C> org.reactivestreams.Subscriber<T> |
SubscriberFactory.create(Function<org.reactivestreams.Subscription,C> subscriptionHandler,
BiConsumer<T,SubscriptionWithContext<C>> dataConsumer,
BiConsumer<Throwable,C> errorConsumer)
Create a
Subscriber reacting onNext, onError. |
static <T,C> org.reactivestreams.Subscriber<T> |
SubscriberFactory.create(Function<org.reactivestreams.Subscription,C> subscriptionHandler,
BiConsumer<T,SubscriptionWithContext<C>> dataConsumer,
BiConsumer<Throwable,C> errorConsumer,
Consumer<C> completeConsumer)
Create a
Subscriber reacting onNext, onSubscribe, onError, onComplete with the passed BiConsumer . |
static <T> org.reactivestreams.Subscriber<T> |
SubscriberFactory.unbounded(BiConsumer<T,SubscriptionWithContext<Void>> dataConsumer)
Create a
Subscriber reacting onNext. |
static <T> org.reactivestreams.Subscriber<T> |
SubscriberFactory.unbounded(BiConsumer<T,SubscriptionWithContext<Void>> dataConsumer,
Consumer<Throwable> errorConsumer)
Create a
Subscriber reacting onNext and onError. |
static <T> org.reactivestreams.Subscriber<T> |
SubscriberFactory.unbounded(BiConsumer<T,SubscriptionWithContext<Void>> dataConsumer,
Consumer<Throwable> errorConsumer,
Consumer<Void> completeConsumer)
Create a
Subscriber reacting onNext, onError and onComplete. |
Copyright © 2016. All rights reserved.