Top Description Inners Fields Constructors Methods
io.reactivex.internal.operators.flowable

public final Class FlowablePublishMulticast<T, R>

extends AbstractFlowableWithUpstream<T, R>
Class Inheritance
Type Parameters
<T>
the input value type
<R>
the output value type
Imports
java.util.concurrent.atomic.*, org.reactivestreams.*, io.reactivex.*, io.reactivex.disposables.Disposable, io.reactivex.exceptions.*, io.reactivex.functions.Function, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.fuseable.*, io.reactivex.internal.subscriptions.*, io.reactivex.internal.util.*, io.reactivex.plugins.RxJavaPlugins
Multicasts a Flowable over a selector function.

Nested and Inner Type Summary

Modifier and TypeClass 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 TypeField 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.internal.operators.flowable.AbstractFlowableWithUpstream:
source

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Subscriber<? super R>
the incoming Subscriber, never null
s)

Implements abstract io.reactivex.Flowable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Subscribers.
Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:
source