Top Description Fields Constructors Methods
reactor.netty.channel

pack-priv final Class FluxReceive

extends Flux<Object>
implements Subscription, Disposable
Class Inheritance
All Implemented Interfaces
reactor.core.Disposable, org.reactivestreams.Subscription
Imports
java.nio.channels.ClosedChannelException, java.util.ArrayDeque, .Queue, java.util.concurrent.atomic.AtomicReferenceFieldUpdater, java.util.function.IntConsumer, io.netty.buffer.ByteBuf, .ByteBufHolder, io.netty.channel.Channel, .EventLoop, io.netty.util.ReferenceCountUtil, org.reactivestreams.Subscription, reactor.core.CoreSubscriber, .Disposable, reactor.core.publisher.Flux, .Operators, reactor.util.Logger, .Loggers, reactor.util.annotation.Nullable
An inbound-traffic API delegating to an underlying Channel.
Author
Stephane Maldini

Field Summary

Modifier and TypeField 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 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 boolean
subscribedOnce

pack-priv int
wip

Constructor Summary

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

Method Summary

Modifier and TypeMethod 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 String
toString(boolean logErrorMessage)

pack-priv final void
unsubscribeReceiver()

Inherited from reactor.core.publisher.Flux:
allanyasblockFirstblockFirstblockLastblockLastbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferTimeoutbufferTimeoutbufferTimeoutbufferTimeoutbufferTimeoutbufferTimeoutbufferTimeoutbufferTimeoutbufferUntilbufferUntilbufferUntilChangedbufferUntilChangedbufferUntilChangedbufferWhenbufferWhenbufferWhilecachecachecachecachecachecachecancelOncastcheckpointcheckpointcheckpointcollectcollectcollectListcollectMapcollectMapcollectMapcollectMultimapcollectMultimapcollectMultimapcollectSortedListcollectSortedListcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestconcatconcatconcatconcatconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatMapconcatMapconcatMapDelayErrorconcatMapDelayErrorconcatMapDelayErrorconcatMapIterableconcatMapIterableconcatWithconcatWithValuescontextCapturecontextWritecontextWritecountcreatecreatedefaultIfEmptydeferdeferContextualdelayElementsdelayElementsdelaySequencedelaySequencedelaySubscriptiondelaySubscriptiondelaySubscriptiondelayUntildematerializedistinctdistinctdistinctdistinctdistinctUntilChangeddistinctUntilChangeddistinctUntilChangeddoAfterTerminatedoFinallydoFirstdoOnCanceldoOnCompletedoOnDiscarddoOnEachdoOnErrordoOnErrordoOnErrordoOnNextdoOnRequestdoOnSubscribedoOnTerminateelapsedelapsedelementAtelementAtemptyerrorerrorerrorexpandexpandexpandDeepexpandDeepfilterfilterWhenfilterWhenfirstfirstfirstWithSignalfirstWithSignalfirstWithValuefirstWithValueflatMapflatMapflatMapflatMapflatMapDelayErrorflatMapIterableflatMapIterableflatMapSequentialflatMapSequentialflatMapSequentialflatMapSequentialDelayErrorfromfromArrayfromIterablefromStreamfromStreamgenerategenerategenerategetPrefetchgroupBygroupBygroupBygroupBygroupJoinhandlehasElementhasElementshideignoreElementsindexindexintervalintervalintervalintervaljoinjustjustlastlastlimitRatelimitRatelimitRequestloglogloglogloglogmapmapNotNullmaterializemergemergemergemergemergemergemergeComparingmergeComparingmergeComparingmergeComparingDelayErrormergeComparingWithmergeDelayErrormergeOrderedmergeOrderedmergeOrderedmergeOrderedWithmergePrioritymergePrioritymergePrioritymergePriorityDelayErrormergeSequentialmergeSequentialmergeSequentialmergeSequentialmergeSequentialmergeSequentialmergeSequentialDelayErrormergeSequentialDelayErrormergeSequentialDelayErrormergeWithmetricsnamenevernextofTypeonAssemblyonAssemblyonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureBufferonBackpressureDroponBackpressureDroponBackpressureErroronBackpressureLatestonErrorCompleteonErrorCompleteonErrorCompleteonErrorContinueonErrorContinueonErrorContinueonErrorMaponErrorMaponErrorMaponErrorResumeonErrorResumeonErrorResumeonErrorReturnonErrorReturnonErrorReturnonErrorStoponTerminateDetachorparallelparallelparallelpublishpublishpublishpublishpublishNextpublishOnpublishOnpublishOnpushpushrangereducereducereduceWithrepeatrepeatrepeatrepeatrepeatWhenreplayreplayreplayreplayreplayreplayretryretryretryWhensamplesamplesampleFirstsampleFirstsampleTimeoutsampleTimeoutscanscanscanWithshareshareNextsinglesinglesingleOrEmptyskipskipskipskipLastskipUntilskipUntilOtherskipWhilesortsortstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeOnsubscribeWithswitchIfEmptyswitchMapswitchMapswitchOnFirstswitchOnFirstswitchOnNextswitchOnNexttagtaketaketaketaketakeLasttakeUntiltakeUntilOthertakeWhiletaptaptapthenthenthenEmptythenManytimedtimedtimeouttimeouttimeouttimeouttimeouttimeouttimeouttimestamptimestamptoIterabletoIterabletoIterabletoStreamtoStreamtransformtransformDeferredtransformDeferredContextualusingusingusingWhenusingWhenwindowwindowwindowwindowwindowwindowwindowwindowTimeoutwindowTimeoutwindowTimeoutwindowTimeoutwindowUntilwindowUntilwindowUntilwindowUntilChangedwindowUntilChangedwindowUntilChangedwindowWhenwindowWhilewindowWhilewithLatestFromzipzipzipzipzipzipzipzipzipzipzipzipzipzipWithzipWithzipWithzipWithzipWithIterablezipWithIterable

Field Detail

CANCELback to summary
pack-priv static final AtomicReferenceFieldUpdater<FluxReceive, IntConsumer> CANCEL
CANCELLEDback to summary
pack-priv static final IntConsumer CANCELLED
channelback to summary
pack-priv final Channel channel
eventLoopback to summary
pack-priv final EventLoop eventLoop
inboundDoneback to summary
pack-priv volatile boolean inboundDone
inboundErrorback to summary
pack-priv Throwable inboundError
logback to summary
pack-priv static final Logger log
logLeakDetectionback to summary
pack-priv static final Logger logLeakDetection
needReadback to summary
pack-priv boolean needRead
parentback to summary
pack-priv final ChannelOperations<?, ?> parent
QUEUE_LOW_LIMITback to summary
pack-priv static final int QUEUE_LOW_LIMIT
receiverback to summary
pack-priv CoreSubscriber<? super Object> receiver
receiverCancelback to summary
pack-priv volatile IntConsumer receiverCancel
receiverDemandback to summary
pack-priv long receiverDemand
receiverFastpathback to summary
pack-priv boolean receiverFastpath
receiverQueueback to summary
pack-priv Queue<Object> receiverQueue
subscribedOnceback to summary
pack-priv boolean subscribedOnce
wipback to summary
pack-priv int wip

Constructor Detail

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

Method Detail

cancelback 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
cancelReceiverback to summary
pack-priv final void cancelReceiver(int cancelCode)
cleanQueueback to summary
pack-priv final void cleanQueue(Queue<Object> q)
disposeback 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
disposeAndUnsubscribeReceiverback to summary
pack-priv final void disposeAndUnsubscribeReceiver()
doCancelback to summary
pack-priv final void doCancel(int cancelCode)
drainReceiverback to summary
pack-priv final void drainReceiver()
getPendingback to summary
pack-priv final long getPending()
isCancelledback to summary
pack-priv final boolean isCancelled()
isDisposedback 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
onInboundCompleteback to summary
pack-priv final void onInboundComplete()
onInboundErrorback to summary
pack-priv final void onInboundError(Throwable err)
onInboundNextback to summary
pack-priv final void onInboundNext(Object msg)
requestback 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
startReceiverback to summary
pack-priv final void startReceiver(CoreSubscriber<? super Object> s)
subscribeback 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
terminateReceiverback to summary
pack-priv final void terminateReceiver(Queue<?> q, CoreSubscriber<?> a)
toStringback 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
toStringback to summary
pack-priv final String toString(boolean logErrorMessage)
unsubscribeReceiverback to summary
pack-priv final void unsubscribeReceiver()