rsocket-core 1.1.4 · io.rsocket.internal.UnboundedProcessor

Modifier and Type	Field and Description
pack-priv CoreSubscriber<? super ByteBuf>	actual
pack-priv boolean	cancelled
pack-priv static final AtomicIntegerFieldUpdater<UnboundedProcessor>	DISCARD_GUARD
pack-priv volatile int	discardGuard
pack-priv boolean	done
pack-priv Throwable	error
pack-priv static final long	FLAG_CANCELLED
pack-priv static final long	FLAG_DISPOSED
pack-priv static final long	FLAG_FINALIZED
pack-priv static final long	FLAG_HAS_REQUEST
pack-priv static final long	FLAG_HAS_VALUE
pack-priv static final long	FLAG_SUBSCRIBED_ONCE
pack-priv static final long	FLAG_SUBSCRIBER_READY
pack-priv static final long	FLAG_TERMINATED
pack-priv ByteBuf	last
pack-priv static final long	MAX_WIP_VALUE
pack-priv final Runnable	onFinalizedHook
pack-priv boolean	outputFused
pack-priv final Queue<ByteBuf>	priorityQueue
pack-priv final Queue<ByteBuf>	queue
pack-priv volatile long	requested
pack-priv static final AtomicLongFieldUpdater<UnboundedProcessor>	REQUESTED
pack-priv volatile long	state
pack-priv static final AtomicLongFieldUpdater<UnboundedProcessor>	STATE

Access	Constructor and Description
public	UnboundedProcessor()
public	UnboundedProcessor(Runnable onFinalizedHook)

Method Summary

Modifier and Type	Method and Description
pack-priv static long	addWork(long state)
public void	cancel() Implements org.reactivestreams.Subscription.cancel. Request the `Publisher` to stop sending data and clean up resources.
pack-priv boolean	checkTerminated(boolean done, boolean empty, CoreSubscriber<? super ByteBuf> a)
public void	clear() Implements java.util.Collection.clear. Clears all elements from queues and set state to terminate.
pack-priv static void	clearAndFinalize(UnboundedProcessor instance) Set flag `FLAG_FINALIZED` and `release(ByteBuf)` all the elements from `queue` and `priorityQueue`.
pack-priv void	clearSafely()
pack-priv void	clearUnsafely()
public Context	currentContext() Overrides default reactor.core.CoreSubscriber.currentContext. Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `org.reactivestreams.Subscriber`.
public void	dispose() Implements reactor.core.Disposable.dispose. Deprecated Cancel or dispose the underlying task or resource.
pack-priv void	drainRegular(long previousState)
public int	getPrefetch() Overrides reactor.core.publisher.Flux.getPrefetch. The prefetch configuration of the `Flux`
pack-priv boolean	hasDownstreams()
pack-priv static boolean	hasRequest(long state)
pack-priv static boolean	hasValue(long state)
public Stream<Scannable>	inners() Overrides default reactor.core.Scannable.inners. Return a `Stream` of referenced inners (flatmap, multicast etc)
pack-priv static boolean	isCancelled(long state)
public boolean	isDisposed() Overrides default reactor.core.Disposable.isDisposed. Optionally return true when the resource or task is disposed.
pack-priv static boolean	isDisposed(long state)
public boolean	isEmpty() Implements java.util.Collection.isEmpty. Returns `true` if this collection contains no elements.
pack-priv static boolean	isFinalized(long state)
pack-priv static boolean	isSubscribedOnce(long state)
pack-priv static boolean	isSubscriberReady(long state)
pack-priv static boolean	isTerminated(long state)
pack-priv static boolean	isWorkInProgress(long state)
pack-priv static long	Returns: previous state markCancelled(UnboundedProcessor instance) Sets `FLAG_CANCELLED` flag if it was not set before and if flag `FLAG_FINALIZED` is unset.
pack-priv static long	Returns: previous state markDisposed(UnboundedProcessor instance) Sets `FLAG_DISPOSED` flag if it was not set before and if flags `FLAG_FINALIZED`, `FLAG_CANCELLED` are unset.
pack-priv static long	Returns: previous state markRequestAdded(UnboundedProcessor instance) Sets `FLAG_HAS_REQUEST` flag if it was not set before and if flags `FLAG_FINALIZED`, `FLAG_CANCELLED`, `FLAG_DISPOSED` are unset.
pack-priv static long	Returns: `true` if `FLAG_SUBSCRIBED_ONCE` was successfully set markSubscribedOnce(UnboundedProcessor instance) Sets `FLAG_SUBSCRIBED_ONCE` flag if it was not set before and if flags `FLAG_FINALIZED`, `FLAG_CANCELLED` or `FLAG_DISPOSED` are unset
pack-priv static long	Returns: previous state markSubscriberReady(UnboundedProcessor instance) Sets `FLAG_SUBSCRIBER_READY` flag if flags `FLAG_FINALIZED`, `FLAG_CANCELLED` or `FLAG_DISPOSED` are unset
pack-priv static long	Returns: previous state markTerminatedOrFinalized(UnboundedProcessor instance) Sets `FLAG_TERMINATED` flag if it was not set before and if flags `FLAG_FINALIZED`, `FLAG_CANCELLED`, `FLAG_DISPOSED` are unset.
pack-priv static long	Returns: previous state markValueAdded(UnboundedProcessor instance) Sets `FLAG_HAS_VALUE` flag if it was not set before and if flags `FLAG_FINALIZED`, `FLAG_CANCELLED`, `FLAG_DISPOSED` are unset.
pack-priv static long	Returns: previous state markValueAddedAndTerminated(UnboundedProcessor instance) Sets `FLAG_HAS_VALUE` flag if it was not set before and if flags `FLAG_FINALIZED`, `FLAG_CANCELLED`, `FLAG_DISPOSED` are unset.
pack-priv static long	Returns: state after changing WIP or current state if update failed markWorkDone(UnboundedProcessor instance, long expectedState, boolean hasRequest, boolean hasValue) Decrements the amount of work in progress by the given amount on the given state.
public void	onComplete() Implements org.reactivestreams.Subscriber.onComplete. Deprecated Successful terminal state.
public void	onError(Throwable the throwable signaled t) Implements org.reactivestreams.Subscriber.onError. Deprecated Failed terminal state.
public void	onNext(ByteBuf the element signaled t) Implements org.reactivestreams.Subscriber.onNext. Deprecated Data notification sent by the `Publisher` in response to requests to `Subscription#request(long)`.
public void	onNextPrioritized(ByteBuf t) Deprecated
public void	onSubscribe(Subscription the `Subscription` that allows requesting data via `Subscription#request(long)` s) Implements reactor.core.CoreSubscriber.onSubscribe. Implementors should initialize any state used by `onNext(Object)` before calling `Subscription#request(long)`.
public ByteBuf	poll() Implements java.util.Queue.poll. Retrieves and removes the head of this queue, or returns `null` if this queue is empty.
pack-priv static void	release(ByteBuf byteBuf)
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.
public int	requestFusion(int the mode requested by the intermediate operator requestedMode) Implements reactor.core.Fuseable.QueueSubscription.requestFusion. Request a specific fusion mode from this QueueSubscription.
public Object	scanUnsafe(Scannable.Attr<T> a `Attr` to resolve for the component. key) Implements reactor.core.Scannable.scanUnsafe. This method is used internally by components to define their key-value mappings in a single place.
public int	size() Implements java.util.Collection.size. Returns the number of elements in this collection.
public void	subscribe(CoreSubscriber<? super ByteBuf> the `Subscriber` interested into the published sequence actual) Implements abstract reactor.core.publisher.Flux.subscribe. Implements reactor.core.CorePublisher.subscribe. An internal `Publisher#subscribe(Subscriber)` that will bypass `Hooks#onLastOperator(Function)` pointcut.
public boolean	tryEmitFinal(ByteBuf t)
public boolean	tryEmitNormal(ByteBuf t)
public boolean	tryEmitPrioritized(ByteBuf t)

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 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 toString 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

public final Class UnboundedProcessor

Field Summary

Constructor Summary

Method Summary