Uses of Class
io.reactivex.rxjava3.processors.UnicastProcessor
-
Packages that use UnicastProcessor Package Description io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
. -
-
Uses of UnicastProcessor in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as UnicastProcessor Modifier and Type Field Description (package private) UnicastProcessor<T>
FlowableWindow.WindowExactSubscriber. window
(package private) UnicastProcessor<T>
FlowableWindow.WindowSkipSubscriber. window
(package private) UnicastProcessor<T>
FlowableWindowBoundary.WindowBoundaryMainSubscriber. window
(package private) 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 UnicastProcessor Modifier and Type Field Description (package private) java.util.Map<java.lang.Integer,UnicastProcessor<TRight>>
FlowableGroupJoin.GroupJoinSubscription. lefts
(package private) SpscLinkedArrayQueue<UnicastProcessor<T>>
FlowableWindow.WindowOverlapSubscriber. queue
(package private) java.util.ArrayDeque<UnicastProcessor<T>>
FlowableWindow.WindowOverlapSubscriber. windows
(package private) java.util.List<UnicastProcessor<T>>
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber. windows
(package private) java.util.List<UnicastProcessor<T>>
FlowableWindowTimed.WindowSkipSubscriber. windows
Methods in io.reactivex.rxjava3.internal.operators.flowable that return UnicastProcessor Modifier and Type Method Description (package private) UnicastProcessor<T>
FlowableWindowTimed.WindowExactBoundedSubscriber. createNewWindow(UnicastProcessor<T> window)
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type UnicastProcessor Modifier and Type Method Description (package private) UnicastProcessor<T>
FlowableWindowTimed.WindowExactBoundedSubscriber. createNewWindow(UnicastProcessor<T> window)
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type UnicastProcessor Constructor Description 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 UnicastProcessor Modifier and Type Method Description static <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>
UnicastProcessor. create(int capacityHint, @NonNull java.lang.Runnable onTerminate)
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>
UnicastProcessor. create(int capacityHint, @NonNull java.lang.Runnable onTerminate, boolean delayError)
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.
-