Package | Description |
---|---|
reactor.io.net.impl.netty |
Implementations of the various TCP abstractions based on Netty.
|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action |
Actions are Reactive Streams components derived from Reactive Extensions and beyond.
|
reactor.rx.action.aggregation | |
reactor.rx.action.combination | |
reactor.rx.action.control | |
reactor.rx.action.pair | |
reactor.rx.action.terminal | |
reactor.rx.broadcast |
Broadcasters are akin to Reactive Extensions Subject.
|
reactor.rx.subscription | |
reactor.rx.subscription.support |
Modifier and Type | Field and Description |
---|---|
protected PushSubscription<IN> |
NettyChannelHandlerBridge.channelSubscription |
Modifier and Type | Method and Description |
---|---|
PushSubscription<IN> |
NettyChannelHandlerBridge.subscription() |
Modifier and Type | Method and Description |
---|---|
PushSubscription<O> |
Stream.downstreamSubscription()
Get the current action child subscription
|
Modifier and Type | Method and Description |
---|---|
boolean |
Stream.cancelSubscription(PushSubscription<O> oPushSubscription)
Try cleaning a given subscription from the stream references.
|
Modifier and Type | Field and Description |
---|---|
protected PushSubscription<O> |
Action.downstreamSubscription |
protected PushSubscription<I> |
Action.upstreamSubscription
The upstream request tracker to avoid dispatcher overrun, based on the current
this#capacity |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<O> |
Action.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
boolean reactivePull) |
protected PushSubscription<O> |
Action.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> queue) |
protected PushSubscription<I> |
Action.createTrackingSubscription(org.reactivestreams.Subscription subscription) |
PushSubscription<O> |
Action.downstreamSubscription()
Get the current action child subscription
|
PushSubscription<I> |
Action.getSubscription()
Get the current upstream subscription if any
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
Action.addSubscription(PushSubscription<O> subscription) |
boolean |
Action.cancelSubscription(PushSubscription<O> subscription)
--------------------------------------------------------------------------------------------------------
INTERNALS
--------------------------------------------------------------------------------------------------------
|
protected void |
Action.subscribeWithSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
PushSubscription<O> subscription)
Subscribe a given subscriber and pairs it with a given subscription instead of letting the Stream pick it
automatically.
|
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<T> |
CacheAction.createSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
CompletableQueue<T> queue) |
protected PushSubscription<T> |
BufferShiftAction.createTrackingSubscription(org.reactivestreams.Subscription subscription) |
protected PushSubscription<T> |
BatchAction.createTrackingSubscription(org.reactivestreams.Subscription subscription) |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheAction.subscribeWithSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
PushSubscription<T> subscription) |
Modifier and Type | Class and Description |
---|---|
class |
FanInSubscription<O,E,X,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,X>> |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<O> |
DynamicMergeAction.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
boolean reactivePull) |
protected PushSubscription<ZipAction.Zippable<O>> |
ZipAction.createTrackingSubscription(org.reactivestreams.Subscription subscription) |
protected PushSubscription<CombineLatestAction.Zippable<O>> |
CombineLatestAction.createTrackingSubscription(org.reactivestreams.Subscription subscription) |
Modifier and Type | Method and Description |
---|---|
protected void |
ConcatAction.subscribeWithSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
PushSubscription<T> subscription) |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<O> |
FlowControlAction.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
boolean reactivePull) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReduceByKeyAction.doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
protected void |
ScanByKeyAction.doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<Void> |
AdaptiveConsumerAction.createSubscription(org.reactivestreams.Subscriber<? super Void> subscriber,
boolean reactivePull) |
protected PushSubscription<Void> |
ConsumerAction.createSubscription(org.reactivestreams.Subscriber<? super Void> subscriber,
boolean reactivePull) |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<O> |
Broadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
boolean reactivePull) |
protected PushSubscription<O> |
Broadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> queue) |
protected PushSubscription<O> |
BehaviorBroadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> queue) |
Modifier and Type | Method and Description |
---|---|
protected void |
Broadcaster.subscribeWithSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
PushSubscription<O> subscription) |
Modifier and Type | Class and Description |
---|---|
class |
BatchSubscription<T>
A Subscription wrapper which request
|
class |
DropSubscription<O>
Relationship between a Stream (Publisher) and a Subscriber.
|
class |
FanOutSubscription<O>
A composite subscription used to achieve pub/sub pattern.
|
class |
ReactiveSubscription<O>
Relationship between a Stream (Publisher) and a Subscriber.
|
Modifier and Type | Field and Description |
---|---|
protected static AtomicLongFieldUpdater<PushSubscription> |
PushSubscription.PENDING_UPDATER |
protected static AtomicIntegerFieldUpdater<PushSubscription> |
PushSubscription.TERMINAL_UPDATER |
Modifier and Type | Method and Description |
---|---|
static <O> PushSubscription<O> |
PushSubscription.wrap(org.reactivestreams.Subscription subscription,
org.reactivestreams.Subscriber<? super O> errorSubscriber)
Wrap the subscription behind a push subscription to start tracking its requests
|
Modifier and Type | Method and Description |
---|---|
List<PushSubscription<O>> |
FanOutSubscription.getSubscriptions() |
Modifier and Type | Method and Description |
---|---|
boolean |
FanOutSubscription.add(PushSubscription<O> subscription) |
boolean |
FanOutSubscription.contains(PushSubscription<O> subscription) |
boolean |
FanOutSubscription.remove(PushSubscription<O> subscription) |
Modifier and Type | Method and Description |
---|---|
void |
FanOutSubscription.forEach(Consumer<PushSubscription<O>> consumer) |
Constructor and Description |
---|
FanOutSubscription(Stream<O> publisher,
PushSubscription<O> reactiveSubscriptionA,
PushSubscription<O> reactiveSubscriptionB) |
FanOutSubscription(Stream<O> publisher,
PushSubscription<O> reactiveSubscriptionA,
PushSubscription<O> reactiveSubscriptionB) |
Modifier and Type | Class and Description |
---|---|
class |
WrappedSubscription<O> |
Modifier and Type | Field and Description |
---|---|
protected PushSubscription<O> |
WrappedSubscription.pushSubscription |
Copyright © 2017. All rights reserved.