Top Description Inners Fields Constructors Methods

io.reactivex.rxjava3.internal.operators.flowable

public final Class FlowablePublishMulticast<T, R>

Class Inheritance

extends AbstractFlowableWithUpstream<T, R>

java.lang.Object
io.reactivex.rxjava3.core.Flowable
io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream
io.reactivex.rxjava3.internal.operators.flowable.FlowablePublishMulticast

Type Parameters

<T>: the input value type
<R>: the output value type

Imports

java.util.Objects, java.util.concurrent.atomic.*, org.reactivestreams.*, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.exceptions.*, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.internal.subscriptions.*, io.reactivex.rxjava3.internal.util.*, io.reactivex.rxjava3.operators.QueueSubscription, .SimpleQueue, io.reactivex.rxjava3.plugins.RxJavaPlugins

Multicasts a Flowable over a selector function.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	FlowablePublishMulticast.MulticastProcessor<T>
pack-priv static class	FlowablePublishMulticast.MulticastSubscription<T>
pack-priv static class	FlowablePublishMulticast.OutputCanceller<R>

Field Summary

Modifier and Type	Field and Description
pack-priv final boolean	delayError
pack-priv final int	prefetch
pack-priv final Function<? super Flowable<T>, ? extends Publisher<? extends R>>	selector

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:: source

Constructor Summary

Access	Constructor and Description
public	FlowablePublishMulticast(Flowable<T> source, Function<? super Flowable<T>, ? extends Publisher<? extends R>> selector, int prefetch, boolean delayError)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(Subscriber<? super R> s)

Inherited from io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream:: source