Uses of Class
io.reactivex.rxjava3.observables.ConnectableObservable

Packages that use ConnectableObservable

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.observable
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 ConnectableObservable in io.reactivex.rxjava3.core

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

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

Uses of ConnectableObservable in io.reactivex.rxjava3.internal.operators.observable

Subclasses of ConnectableObservable in io.reactivex.rxjava3.internal.operators.observable

Modifier and Type	Class	Description
class	ObservablePublish<T>	Shares a single underlying connection to the upstream ObservableSource and multicasts events to all subscribed observers until the upstream completes or the connection is disposed.
class	ObservableReplay<T>

Fields in io.reactivex.rxjava3.internal.operators.observable declared as ConnectableObservable

Modifier and Type	Field	Description
(package private) ConnectableObservable<? extends T>	ObservableAutoConnect.source
(package private) ConnectableObservable<T>	ObservableRefCount.source

Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type ConnectableObservable

Modifier and Type	Field	Description
private Supplier<? extends ConnectableObservable<U>>	ObservableReplay.MulticastReplay.connectableFactory

Methods in io.reactivex.rxjava3.internal.operators.observable that return ConnectableObservable

Modifier and Type	Method	Description
static <T> ConnectableObservable<T>	ObservableReplay.create(ObservableSource<T> source, int bufferSize, boolean eagerTruncate)	Creates a replaying ConnectableObservable with a size bound buffer.
static <T> ConnectableObservable<T>	ObservableReplay.create(ObservableSource<T> source, long maxAge, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)	Creates a replaying ConnectableObservable with a time bound buffer.
static <T> ConnectableObservable<T>	ObservableReplay.create(ObservableSource<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> ConnectableObservable<T>	ObservableReplay.create(ObservableSource<T> source, ObservableReplay.BufferSupplier<T> bufferFactory)	Creates a OperatorReplay instance to replay values of the given source observable.
static <T> ConnectableObservable<T>	ObservableReplay.createFrom(ObservableSource<? extends T> source)	Creates a replaying ConnectableObservable with an unbounded buffer.
ConnectableObservable<T>	ObservableInternalHelper.BufferedReplaySupplier.get()
ConnectableObservable<T>	ObservableInternalHelper.BufferedTimedReplaySupplier.get()
ConnectableObservable<T>	ObservableInternalHelper.ReplaySupplier.get()
ConnectableObservable<T>	ObservableInternalHelper.TimedReplayCallable.get()

Methods in io.reactivex.rxjava3.internal.operators.observable that return types with arguments of type ConnectableObservable

Modifier and Type	Method	Description
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent)
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent, int bufferSize, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent, int bufferSize, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
static <T> Supplier<ConnectableObservable<T>>	ObservableInternalHelper.replaySupplier(Observable<T> parent, long time, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)

Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ConnectableObservable

Modifier and Type	Method	Description
static <U,R> Observable<R>	ObservableReplay.multicastSelector(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>,? extends ObservableSource<R>> selector)	Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ConnectableObservable

Constructor	Description
ObservableAutoConnect(ConnectableObservable<? extends T> source, int numberOfObservers, Consumer<? super Disposable> connection)
ObservableRefCount(ConnectableObservable<T> source)
ObservableRefCount(ConnectableObservable<T> source, int n, long timeout, java.util.concurrent.TimeUnit unit, Scheduler scheduler)

Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ConnectableObservable

Constructor	Description
MulticastReplay(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>,? extends ObservableSource<R>> selector)

Uses of ConnectableObservable in io.reactivex.rxjava3.plugins

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

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

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

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

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

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

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

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

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

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