Uses of Class
io.reactivex.rxjava3.processors.UnicastProcessor
Packages that use UnicastProcessor
Package
Description
Classes representing so-called hot backpressure-aware sources, aka processors,
that implement the
FlowableProcessor
class,
the Reactive Streams Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams Publisher
.-
Uses of UnicastProcessor in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as UnicastProcessorModifier and TypeFieldDescription(package private) UnicastProcessor
<T> FlowableWindow.WindowExactSubscriber.window
(package private) UnicastProcessor
<T> FlowableWindow.WindowSkipSubscriber.window
(package private) UnicastProcessor
<T> FlowableWindowBoundary.WindowBoundaryMainSubscriber.window
(package private) final UnicastProcessor
<T> FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept.window
(package private) UnicastProcessor
<T> FlowableWindowTimed.WindowExactBoundedSubscriber.window
(package private) UnicastProcessor
<T> FlowableWindowTimed.WindowExactUnboundedSubscriber.window
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type UnicastProcessorModifier and TypeFieldDescription(package private) final Map
<Integer, UnicastProcessor<TRight>> FlowableGroupJoin.GroupJoinSubscription.lefts
(package private) final SpscLinkedArrayQueue
<UnicastProcessor<T>> FlowableWindow.WindowOverlapSubscriber.queue
(package private) final ArrayDeque
<UnicastProcessor<T>> FlowableWindow.WindowOverlapSubscriber.windows
(package private) final List
<UnicastProcessor<T>> FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.windows
(package private) final List
<UnicastProcessor<T>> FlowableWindowTimed.WindowSkipSubscriber.windows
Methods in io.reactivex.rxjava3.internal.operators.flowable that return UnicastProcessorModifier and TypeMethodDescription(package private) UnicastProcessor
<T> FlowableWindowTimed.WindowExactBoundedSubscriber.createNewWindow
(UnicastProcessor<T> window) Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type UnicastProcessorModifier and TypeMethodDescription(package private) UnicastProcessor
<T> FlowableWindowTimed.WindowExactBoundedSubscriber.createNewWindow
(UnicastProcessor<T> window) Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type UnicastProcessorModifierConstructorDescription(package private)
WindowEndSubscriberIntercept
(FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber<T, ?, V> parent, UnicastProcessor<T> window) -
Uses of UnicastProcessor in io.reactivex.rxjava3.processors
Methods in io.reactivex.rxjava3.processors that return UnicastProcessorModifier and TypeMethodDescriptionstatic <T> @NonNull UnicastProcessor
<T> UnicastProcessor.create()
Creates an UnicastSubject with an internal buffer capacity hint 16.static <T> @NonNull UnicastProcessor
<T> UnicastProcessor.create
(boolean delayError) Creates an UnicastProcessor with default internal buffer capacity hint and delay error flag.static <T> @NonNull UnicastProcessor
<T> UnicastProcessor.create
(int capacityHint) Creates an UnicastProcessor with the given internal buffer capacity hint.static <T> @NonNull UnicastProcessor
<T> Creates an UnicastProcessor with the given internal buffer capacity hint and a callback for the case when the single Subscriber cancels its subscription or the processor is terminated.static <T> @NonNull UnicastProcessor
<T> Creates an UnicastProcessor with the given internal buffer capacity hint, delay error flag and a callback for the case when the single Subscriber cancels its subscription or the processor is terminated.