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
`@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 `Subscriber`s that have subscribed to it.
`@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 `Subscriber`s that have subscribed to it.
`@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`.
`@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 `Subscriber`s.
`@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 `Subscriber`s.
`@NonNull ConnectableFlowable<T>`	Flowable.`replay(int bufferSize, long time, @NonNull java.util.concurrent.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.
`@NonNull ConnectableFlowable<T>`	Flowable.`replay(int bufferSize, long time, @NonNull java.util.concurrent.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 `Subscriber`s.
`@NonNull ConnectableFlowable<T>`	Flowable.`replay(int bufferSize, long time, @NonNull java.util.concurrent.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 `Subscriber`s.
`@NonNull ConnectableFlowable<T>`	Flowable.`replay(long time, @NonNull java.util.concurrent.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 `Subscriber`s.
`@NonNull ConnectableFlowable<T>`	Flowable.`replay(long time, @NonNull java.util.concurrent.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 `Subscriber`s.
`@NonNull ConnectableFlowable<T>`	Flowable.`replay(long time, @NonNull java.util.concurrent.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 `Subscriber`s.

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
`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.
`class`	`FlowableReplay<T>`

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ConnectableFlowable
Modifier and Type	Field	Description
`(package private) ConnectableFlowable<? extends T>`	FlowableAutoConnect.`source`
`(package private) ConnectableFlowable<T>`	FlowableRefCount.`source`

Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type ConnectableFlowable
Modifier and Type	Field	Description
`private 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, java.util.concurrent.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, java.util.concurrent.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, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)`
`static <T> Supplier<ConnectableFlowable<T>>`	FlowableInternalHelper.`replaySupplier(Flowable<T> parent, long time, java.util.concurrent.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
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, java.util.concurrent.TimeUnit unit, Scheduler scheduler)`

Constructor parameters in io.reactivex.rxjava3.internal.operators.flowable with type arguments of type ConnectableFlowable
Constructor	Description
`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.