Core functionality for the Reactor Netty library 2.0.0-M3 · reactor.netty5.channel.FluxReceive

Field Summary

Modifier and Type	Field and Description
pack-priv static final AtomicReferenceFieldUpdater<FluxReceive, IntConsumer>	CANCEL
pack-priv static final IntConsumer	CANCELLED
pack-priv final Channel	channel
pack-priv final EventLoop	eventLoop
pack-priv volatile boolean	inboundDone
pack-priv Throwable	inboundError
pack-priv static final Logger	log
pack-priv static final Logger	logLeakDetection
pack-priv boolean	needRead
pack-priv volatile int	once
pack-priv static final AtomicIntegerFieldUpdater<FluxReceive>	ONCE
pack-priv final ChannelOperations<?, ?>	parent
pack-priv static final int	QUEUE_LOW_LIMIT
pack-priv CoreSubscriber<? super Object>	receiver
pack-priv volatile IntConsumer	receiverCancel
pack-priv long	receiverDemand
pack-priv boolean	receiverFastpath
pack-priv Queue<Object>	receiverQueue
pack-priv int	wip

Constructor Summary

Access	Constructor and Description
pack-priv	FluxReceive(ChannelOperations<?, ?> parent)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
pack-priv final void	cancelReceiver(int cancelCode)
pack-priv final void	cleanQueue(Queue<Object> q)
public void	dispose() Implements reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource.
pack-priv final void	disposeAndUnsubscribeReceiver()
pack-priv final void	doCancel(int cancelCode)
pack-priv final void	drainReceiver()
pack-priv final long	getPending()
pack-priv final boolean	isCancelled()
public boolean	isDisposed() Overrides default reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed.
pack-priv final void	onInboundComplete()
pack-priv final void	onInboundError(Throwable err)
pack-priv final void	onInboundNext(Object msg)
public void	request(long the strictly positive number of elements to requests to the upstream `Publisher` n) Implements org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method.
pack-priv final void	startReceiver(CoreSubscriber<? super Object> s)
public void	subscribe(CoreSubscriber<? super Object> the `Subscriber` interested into the published sequence s) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.
pack-priv final void	terminateReceiver(Queue<?> q, CoreSubscriber<?> a)
public String	toString() Overrides reactor.core.publisher.Flux.toString. Returns a string representation of the object.
pack-priv final void	unsubscribeReceiver()

Inherited from reactor.core.publisher.Flux:: all any as blockFirst blockFirst blockLast blockLast buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferTimeout bufferUntil bufferUntil bufferUntilChanged bufferUntilChanged bufferUntilChanged bufferWhen bufferWhen bufferWhile cache cache cache cache cache cache cancelOn cast checkpoint checkpoint checkpoint collect collect collectList collectMap collectMap collectMap collectMultimap collectMultimap collectMultimap collectSortedList collectSortedList combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest concat concat concat concat concatDelayError concatDelayError concatDelayError concatDelayError concatMap concatMap concatMapDelayError concatMapDelayError concatMapDelayError concatMapIterable concatMapIterable concatWith concatWithValues contextCapture contextWrite contextWrite count create create defaultIfEmpty defer deferContextual delayElements delayElements delaySequence delaySequence delaySubscription delaySubscription delaySubscription delayUntil dematerialize distinct distinct distinct distinct distinctUntilChanged distinctUntilChanged distinctUntilChanged doAfterTerminate doFinally doFirst doOnCancel doOnComplete doOnDiscard doOnEach doOnError doOnError doOnError doOnNext doOnRequest doOnSubscribe doOnTerminate elapsed elapsed elementAt elementAt empty error error error expand expand expandDeep expandDeep filter filterWhen filterWhen first first firstWithSignal firstWithSignal firstWithValue firstWithValue flatMap flatMap flatMap flatMap flatMapDelayError flatMapIterable flatMapIterable flatMapSequential flatMapSequential flatMapSequential flatMapSequentialDelayError from fromArray fromIterable fromStream fromStream generate generate generate getPrefetch groupBy groupBy groupBy groupBy groupJoin handle hasElement hasElements hide ignoreElements index index interval interval interval interval join just just last last limitRate limitRate limitRequest log log log log log log map mapNotNull materialize merge merge merge merge merge merge mergeComparing mergeComparing mergeComparing mergeComparingDelayError mergeComparingWith mergeDelayError mergeOrdered mergeOrdered mergeOrdered mergeOrderedWith mergePriority mergePriority mergePriority mergePriorityDelayError mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequential mergeSequentialDelayError mergeSequentialDelayError mergeSequentialDelayError mergeWith metrics name never next ofType onAssembly onAssembly onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureBuffer onBackpressureDrop onBackpressureDrop onBackpressureError onBackpressureLatest onErrorComplete onErrorComplete onErrorComplete onErrorContinue onErrorContinue onErrorContinue onErrorMap onErrorMap onErrorMap onErrorResume onErrorResume onErrorResume onErrorReturn onErrorReturn onErrorReturn onErrorStop onTerminateDetach or parallel parallel parallel publish publish publish publish publishNext publishOn publishOn publishOn push push range reduce reduce reduceWith repeat repeat repeat repeat repeatWhen replay replay replay replay replay replay retry retry retryWhen sample sample sampleFirst sampleFirst sampleTimeout sampleTimeout scan scan scanWith share shareNext single single singleOrEmpty skip skip skip skipLast skipUntil skipUntilOther skipWhile sort sort startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribe subscribe subscribeOn subscribeOn subscribeWith switchIfEmpty switchMap switchMap switchOnFirst switchOnFirst switchOnNext switchOnNext tag take take take take takeLast takeUntil takeUntilOther takeWhile tap tap tap then then thenEmpty thenMany timed timed timeout timeout timeout timeout timeout timeout timeout timestamp timestamp toIterable toIterable toIterable toStream toStream transform transformDeferred transformDeferredContextual using using usingWhen usingWhen window window window window window window window windowTimeout windowTimeout windowTimeout windowTimeout windowUntil windowUntil windowUntil windowUntilChanged windowUntilChanged windowUntilChanged windowWhen windowWhile windowWhile withLatestFrom zip zip zip zip zip zip zip zip zip zip zip zip zip zipWith zipWith zipWith zipWith zipWithIterable zipWithIterable

Field Detail

CANCEL	back to summary
pack-priv static final AtomicReferenceFieldUpdater<FluxReceive, IntConsumer> CANCEL

CANCELLED	back to summary
pack-priv static final IntConsumer CANCELLED

channel	back to summary
pack-priv final Channel channel

eventLoop	back to summary
pack-priv final EventLoop eventLoop

inboundDone	back to summary
pack-priv volatile boolean inboundDone

inboundError	back to summary
pack-priv Throwable inboundError

log	back to summary
pack-priv static final Logger log

logLeakDetection	back to summary
pack-priv static final Logger logLeakDetection

needRead	back to summary
pack-priv boolean needRead

once	back to summary
pack-priv volatile int once

ONCE	back to summary
pack-priv static final AtomicIntegerFieldUpdater<FluxReceive> ONCE

parent	back to summary
pack-priv final ChannelOperations<?, ?> parent

QUEUE_LOW_LIMIT	back to summary
pack-priv static final int QUEUE_LOW_LIMIT

receiver	back to summary
pack-priv CoreSubscriber<? super Object> receiver

receiverCancel	back to summary
pack-priv volatile IntConsumer receiverCancel

receiverDemand	back to summary
pack-priv long receiverDemand

receiverFastpath	back to summary
pack-priv boolean receiverFastpath

receiverQueue	back to summary
pack-priv Queue<Object> receiverQueue

wip	back to summary
pack-priv int wip

Constructor Detail

FluxReceive	back to summary
pack-priv FluxReceive(ChannelOperations<?, ?> parent)

Method Detail

cancel back to summary

cancel	back to summary
public void cancel() Implements org.reactivestreams.Subscription.cancel. Doc from org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources. Data may still be sent to meet previously signalled demand after calling cancel. Annotations @Override

public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations

@Override

cancelReceiver	back to summary
pack-priv final void cancelReceiver(int cancelCode)

cleanQueue	back to summary
pack-priv final void cleanQueue(Queue<Object> q)

dispose	back to summary
public void dispose() Implements reactor.core.Disposable.dispose. Doc from reactor.core.Disposable.dispose. Cancel or dispose the underlying task or resource. Implementations are required to make this method idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations

@Override

disposeAndUnsubscribeReceiver	back to summary
pack-priv final void disposeAndUnsubscribeReceiver()

doCancel	back to summary
pack-priv final void doCancel(int cancelCode)

drainReceiver	back to summary
pack-priv final void drainReceiver()

getPending	back to summary
pack-priv final long getPending()

isCancelled	back to summary
pack-priv final boolean isCancelled()

isDisposed	back to summary
public boolean isDisposed() Overrides default reactor.core.Disposable.isDisposed. Doc from reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed. Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed. Returns:boolean true when there's a guarantee the resource or task is disposed. Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations

@Override

onInboundComplete	back to summary
pack-priv final void onInboundComplete()

onInboundError	back to summary
pack-priv final void onInboundError(Throwable err)

onInboundNext	back to summary
pack-priv final void onInboundNext(Object msg)

request back to summary

request	back to summary
public void request(long n) Implements org.reactivestreams.Subscription.request. Doc from org.reactivestreams.Subscription.request. No events will be sent by a `Publisher` until demand is signaled via this method. It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the `Publisher` as "effectively unbounded". Whatever has been requested can be sent by the `Publisher` so only signal demand for what can be safely handled. A `Publisher` can send less than is requested if the stream ends but then must emit either `Subscriber#onError(Throwable)` or `Subscriber#onComplete()`. Parameters n:long the strictly positive number of elements to requests to the upstream `Publisher` Annotations @Override

public void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters

n:long: the strictly positive number of elements to requests to the upstream Publisher

Annotations

@Override

startReceiver	back to summary
pack-priv final void startReceiver(CoreSubscriber<? super Object> s)

subscribe back to summary

subscribe	back to summary
public void subscribe(CoreSubscriber<? super Object> s) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. Doc from reactor.core.publisher.Flux.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut. In addition to behave as expected by `Publisher#subscribe(Subscriber)` in a controlled manner, it supports direct subscribe-time `Context` passing. Parameters s:CoreSubscriber<? super Object> the `Subscriber` interested into the published sequence Annotations @Override

public void subscribe(CoreSubscriber<? super Object> s)

Implements abstract reactor.core.publisher.Flux.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Flux.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.

In addition to behave as expected by Publisher#subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.

Parameters

s:CoreSubscriber<? super Object>: the Subscriber interested into the published sequence

Annotations

@Override

terminateReceiver	back to summary
pack-priv final void terminateReceiver(Queue<?> q, CoreSubscriber<?> a)

toString	back to summary
public String toString() Overrides reactor.core.publisher.Flux.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides reactor.core.publisher.Flux.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

unsubscribeReceiver	back to summary
pack-priv final void unsubscribeReceiver()

pack-priv final Class FluxReceive

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail