Package | Description |
---|---|
reactor.core.reactivestreams | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
Modifier and Type | Field and Description |
---|---|
protected static AtomicIntegerFieldUpdater<SubscriberWithContext> |
SubscriberWithContext.TERMINAL_UPDATER |
Modifier and Type | Method and Description |
---|---|
static <T,C> SubscriberWithContext<T,C> |
SubscriberWithContext.create(org.reactivestreams.Subscriber<? super T> subscriber,
C context)
Attach a given arbitrary context (stateful information) to a
Subscriber , all Subscriber methods
will delegate properly. |
Modifier and Type | Method and Description |
---|---|
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.Publisher<T> |
PublisherFactory.forEach(Consumer<SubscriberWithContext<T,C>> requestConsumer,
Function<org.reactivestreams.Subscriber<? super T>,C> contextFactory)
|
static <T,C> org.reactivestreams.Publisher<T> |
PublisherFactory.forEach(Consumer<SubscriberWithContext<T,C>> requestConsumer,
Function<org.reactivestreams.Subscriber<? super T>,C> contextFactory,
Consumer<C> shutdownConsumer)
|
static <T> org.reactivestreams.Publisher<T> |
PublisherFactory.forEach(Consumer<SubscriberWithContext<T,Void>> requestConsumer)
|
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 |
Copyright © 2016. All rights reserved.