Uses of Class
io.reactivex.rxjava3.flowables.ConnectableFlowable

Packages that use ConnectableFlowable

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.plugins	Contains the central plugin handler RxJavaPlugins class to hook into the lifecycle of the base reactive types and schedulers.

Uses of ConnectableFlowable in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core that return ConnectableFlowable

Modifier and Type	Method	Description
final @NonNull ConnectableFlowable<T>	Flowable.publish()	Returns a ConnectableFlowable, which is a variety of Publisher that waits until its connect method is called before it begins emitting items to those Subscribers that have subscribed to it.
final @NonNull ConnectableFlowable<T>	Flowable.publish(int bufferSize)	Returns a ConnectableFlowable, which is a variety of Publisher that waits until its connect method is called before it begins emitting items to those Subscribers that have subscribed to it.
final @NonNull ConnectableFlowable<T>	Flowable.replay()	Returns a ConnectableFlowable that shares a single subscription to the underlying Publisher that will replay all of its items and notifications to any future Subscriber.
final @NonNull ConnectableFlowable<T>	Flowable.replay(int bufferSize)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays at most bufferSize items to late Subscribers.
final @NonNull ConnectableFlowable<T>	Flowable.replay(int bufferSize, boolean eagerTruncate)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays at most bufferSize items to late Subscribers.
final @NonNull ConnectableFlowable<T>	Flowable.replay(int bufferSize, long time, @NonNull TimeUnit unit)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays at most bufferSize items that were emitted during a specified time window.
final @NonNull ConnectableFlowable<T>	Flowable.replay(int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays a maximum of bufferSize items that are emitted within a specified time window to late Subscribers.
final @NonNull ConnectableFlowable<T>	Flowable.replay(int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays a maximum of bufferSize items that are emitted within a specified time window to late Subscribers.
final @NonNull ConnectableFlowable<T>	Flowable.replay(long time, @NonNull TimeUnit unit)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays all items emitted by it within a specified time window to late Subscribers.
final @NonNull ConnectableFlowable<T>	Flowable.replay(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays all items emitted by it within a specified time window to late Subscribers.
final @NonNull ConnectableFlowable<T>	Flowable.replay(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate)	Returns a ConnectableFlowable that shares a single subscription to the current Flowable and replays all items emitted by it within a specified time window to late Subscribers.

Uses of ConnectableFlowable in io.reactivex.rxjava3.internal.operators.flowable

Subclasses of ConnectableFlowable in io.reactivex.rxjava3.internal.operators.flowable

Modifier and Type	Class	Description
final class	FlowablePublish<T>	Shares a single underlying connection to the upstream Publisher and multicasts events to all subscribed subscribers until the upstream completes or the connection is disposed.
final class	FlowableReplay<T>

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ConnectableFlowable

Modifier and Type	Field	Description
(package private) final ConnectableFlowable<? extends T>	FlowableAutoConnect.source
(package private) final ConnectableFlowable<T>	FlowableRefCount.source

Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type ConnectableFlowable

Modifier and Type	Field	Description
private final Supplier<? extends ConnectableFlowable<U>>	FlowableReplay.MulticastFlowable.connectableFactory

Methods in io.reactivex.rxjava3.internal.operators.flowable that return ConnectableFlowable

Modifier and Type	Method	Description
static <T> ConnectableFlowable<T>	FlowableReplay.create(Flowable<T> source, int bufferSize, boolean eagerTruncate)	Creates a replaying ConnectableObservable with a size bound buffer.
static <T> ConnectableFlowable<T>	FlowableReplay.create(Flowable<T> source, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)	Creates a replaying ConnectableObservable with a time bound buffer.
static <T> ConnectableFlowable<T>	FlowableReplay.create(Flowable<T> source, long maxAge, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean eagerTruncate)	Creates a replaying ConnectableObservable with a size and time bound buffer.
(package private) static <T> ConnectableFlowable<T>	FlowableReplay.create(Flowable<T> source, Supplier<? extends FlowableReplay.ReplayBuffer<T>> bufferFactory)	Creates a OperatorReplay instance to replay values of the given source Flowable.
static <T> ConnectableFlowable<T>	FlowableReplay.createFrom(Flowable<? extends T> source)	Creates a replaying ConnectableObservable with an unbounded buffer.
ConnectableFlowable<T>	FlowableInternalHelper.BufferedReplaySupplier.get()
ConnectableFlowable<T>	FlowableInternalHelper.BufferedTimedReplay.get()
ConnectableFlowable<T>	FlowableInternalHelper.ReplaySupplier.get()
ConnectableFlowable<T>	FlowableInternalHelper.TimedReplay.get()

Methods in io.reactivex.rxjava3.internal.operators.flowable that return types with arguments of type ConnectableFlowable

Modifier and Type	Method	Description
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent)
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent, int bufferSize, boolean eagerTruncate)
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableFlowable<T>>	FlowableInternalHelper.replaySupplier(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)

Method parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type ConnectableFlowable

Modifier and Type	Method	Description
static <U, R> Flowable<R>	FlowableReplay.multicastSelector(Supplier<? extends ConnectableFlowable<U>> connectableFactory, Function<? super Flowable<U>,? extends org.reactivestreams.Publisher<R>> selector)	Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type ConnectableFlowable

Modifier	Constructor	Description
	FlowableAutoConnect(ConnectableFlowable<? extends T> source, int numberOfSubscribers, Consumer<? super Disposable> connection)
	FlowableRefCount(ConnectableFlowable<T> source)
	FlowableRefCount(ConnectableFlowable<T> source, int n, long timeout, TimeUnit unit, Scheduler scheduler)

Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type ConnectableFlowable

Modifier	Constructor	Description
(package private)	MulticastFlowable(Supplier<? extends ConnectableFlowable<U>> connectableFactory, Function<? super Flowable<U>,? extends org.reactivestreams.Publisher<R>> selector)

Uses of ConnectableFlowable in io.reactivex.rxjava3.plugins

Fields in io.reactivex.rxjava3.plugins with type parameters of type ConnectableFlowable

Modifier and Type	Field	Description
(package private) static @Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable>	RxJavaPlugins.onConnectableFlowableAssembly
(package private) static @Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable>	RxJavaPlugins.onConnectableFlowableAssembly

Methods in io.reactivex.rxjava3.plugins that return ConnectableFlowable

Modifier and Type	Method	Description
static <@NonNull T> @NonNull ConnectableFlowable<T>	RxJavaPlugins.onAssembly(@NonNull ConnectableFlowable<@NonNull T> source)	Calls the associated hook function.

Methods in io.reactivex.rxjava3.plugins that return types with arguments of type ConnectableFlowable

Modifier and Type	Method	Description
static @Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable>	RxJavaPlugins.getOnConnectableFlowableAssembly()	Returns the current hook function.
static @Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable>	RxJavaPlugins.getOnConnectableFlowableAssembly()	Returns the current hook function.

Methods in io.reactivex.rxjava3.plugins with parameters of type ConnectableFlowable

Modifier and Type	Method	Description
static <@NonNull T> @NonNull ConnectableFlowable<T>	RxJavaPlugins.onAssembly(@NonNull ConnectableFlowable<@NonNull T> source)	Calls the associated hook function.

Method parameters in io.reactivex.rxjava3.plugins with type arguments of type ConnectableFlowable

Modifier and Type	Method	Description
static void	RxJavaPlugins.setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)	Sets the specific hook function.
static void	RxJavaPlugins.setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)	Sets the specific hook function.