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 theFlowableProcessorclass, the Reactive StreamsProcessorinterface 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. windowFields 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. windowsMethods 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.
-