Package | Description |
---|---|
reactor.core.reactivestreams | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.error |
Modifier and Type | Method and Description |
---|---|
static <I,O> org.reactivestreams.Publisher<O> |
PublisherFactory.barrier(org.reactivestreams.Publisher<I> source,
BiConsumer<I,org.reactivestreams.Subscriber<? super O>> dataConsumer)
Intercept a source
Publisher onNext signal to eventually transform, forward or filter the data by calling
or not
the right operand Subscriber . |
static <I,O> org.reactivestreams.Publisher<O> |
PublisherFactory.barrier(org.reactivestreams.Publisher<I> source,
BiConsumer<I,org.reactivestreams.Subscriber<? super O>> dataConsumer,
BiConsumer<Throwable,org.reactivestreams.Subscriber<? super O>> errorConsumer)
Intercept a source
Publisher onNext signal to eventually transform, forward or filter the data by calling
or not
the right operand Subscriber . |
static <I,O> org.reactivestreams.Publisher<O> |
PublisherFactory.barrier(org.reactivestreams.Publisher<I> source,
BiConsumer<I,org.reactivestreams.Subscriber<? super O>> dataConsumer,
BiConsumer<Throwable,org.reactivestreams.Subscriber<? super O>> errorConsumer)
Intercept a source
Publisher onNext signal to eventually transform, forward or filter the data by calling
or not
the right operand Subscriber . |
static <I,O> org.reactivestreams.Publisher<O> |
PublisherFactory.barrier(org.reactivestreams.Publisher<I> source,
BiConsumer<I,org.reactivestreams.Subscriber<? super O>> dataConsumer,
BiConsumer<Throwable,org.reactivestreams.Subscriber<? super O>> errorConsumer,
Consumer<org.reactivestreams.Subscriber<? super O>> completeConsumer)
Intercept a source
Publisher onNext signal to eventually transform, forward or filter the data by calling
or not
the right operand Subscriber . |
static <I,O> org.reactivestreams.Publisher<O> |
PublisherFactory.barrier(org.reactivestreams.Publisher<I> source,
BiConsumer<I,org.reactivestreams.Subscriber<? super O>> dataConsumer,
BiConsumer<Throwable,org.reactivestreams.Subscriber<? super O>> errorConsumer,
Consumer<org.reactivestreams.Subscriber<? super O>> completeConsumer)
Intercept a source
Publisher onNext signal to eventually transform, forward or filter the data by calling
or not
the right operand Subscriber . |
static <T,C> org.reactivestreams.Publisher<T> |
PublisherFactory.create(BiConsumer<Long,SubscriberWithContext<T,C>> requestConsumer,
Function<org.reactivestreams.Subscriber<? super T>,C> contextFactory)
Create a
Publisher reacting on requests with the passed BiConsumer
The argument contextFactory is executed once by new subscriber to generate a context shared by every
request calls. |
static <T,C> org.reactivestreams.Publisher<T> |
PublisherFactory.create(BiConsumer<Long,SubscriberWithContext<T,C>> requestConsumer,
Function<org.reactivestreams.Subscriber<? super T>,C> contextFactory,
Consumer<C> shutdownConsumer)
Create a
Publisher reacting on requests with the passed BiConsumer . |
static <T> org.reactivestreams.Publisher<T> |
PublisherFactory.create(BiConsumer<Long,SubscriberWithContext<T,Void>> requestConsumer)
Create a
Publisher reacting on requests with the passed BiConsumer |
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)
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,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. |
Modifier and Type | Method and Description |
---|---|
static <T,C> Stream<T> |
Streams.createWith(BiConsumer<Long,SubscriberWithContext<T,C>> requestConsumer,
Function<org.reactivestreams.Subscriber<? super T>,C> contextFactory)
Create a
Stream reacting on requests with the passed BiConsumer
The argument contextFactory is executed once by new subscriber to generate a context shared by every
request calls. |
static <T,C> Stream<T> |
Streams.createWith(BiConsumer<Long,SubscriberWithContext<T,C>> requestConsumer,
Function<org.reactivestreams.Subscriber<? super T>,C> contextFactory,
Consumer<C> shutdownConsumer)
Create a
Stream reacting on requests with the passed BiConsumer . |
static <T> Stream<T> |
Streams.createWith(BiConsumer<Long,SubscriberWithContext<T,Void>> requestConsumer)
Create a
Stream reacting on requests with the passed BiConsumer |
<E extends Throwable> |
Stream.observeError(Class<E> exceptionType,
BiConsumer<Object,? super E> onError)
Assign an error handler that will pass eventual associated values and exceptions of the given type.
|
Constructor and Description |
---|
ErrorWithValueAction(Class<E> selector,
BiConsumer<Object,? super E> consumer,
org.reactivestreams.Publisher<? extends T> fallback) |
Copyright © 2017. All rights reserved.