Uses of Class
io.reactivex.rxjava3.observables.ConnectableObservable
Packages that use ConnectableObservable
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.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 ConnectableObservableModifier and TypeMethodDescriptionfinal @NonNull ConnectableObservable
<T> Observable.publish()
Returns aConnectableObservable
, which is a variety ofObservableSource
that waits until itsconnect
method is called before it begins emitting items to thoseObserver
s that have subscribed to it.final @NonNull ConnectableObservable
<T> Observable.replay()
Returns aConnectableObservable
that shares a single subscription to the currentObservable
that will replay all of its items and notifications to any futureObserver
.final @NonNull ConnectableObservable
<T> Observable.replay
(int bufferSize) Returns aConnectableObservable
that shares a single subscription to the currentObservable
that replays at mostbufferSize
items emitted by the currentObservable
.final @NonNull ConnectableObservable
<T> Observable.replay
(int bufferSize, boolean eagerTruncate) Returns aConnectableObservable
that shares a single subscription to the currentObservable
that replays at mostbufferSize
items emitted by the currentObservable
.final @NonNull ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays at mostbufferSize
items that were emitted during a specified time window.final @NonNull ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the currentObservable
and that replays a maximum ofbufferSize
items that are emitted within a specified time window.final @NonNull ConnectableObservable
<T> Observable.replay
(int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableObservable
that shares a single subscription to the currentObservable
and that replays a maximum ofbufferSize
items that are emitted within a specified time window.final @NonNull ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window.final @NonNull ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window.final @NonNull ConnectableObservable
<T> Observable.replay
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window. -
Uses of ConnectableObservable in io.reactivex.rxjava3.internal.operators.observable
Subclasses of ConnectableObservable in io.reactivex.rxjava3.internal.operators.observableModifier and TypeClassDescriptionfinal class
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.final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ConnectableObservableModifier and TypeFieldDescription(package private) final ConnectableObservable
<? extends T> ObservableAutoConnect.source
(package private) final ConnectableObservable
<T> ObservableRefCount.source
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type ConnectableObservableModifier and TypeFieldDescriptionprivate final Supplier
<? extends ConnectableObservable<U>> ObservableReplay.MulticastReplay.connectableFactory
Methods in io.reactivex.rxjava3.internal.operators.observable that return ConnectableObservableModifier and TypeMethodDescriptionstatic <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, 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, 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.ObservableInternalHelper.BufferedReplaySupplier.get()
ObservableInternalHelper.BufferedTimedReplaySupplier.get()
ObservableInternalHelper.ReplaySupplier.get()
ObservableInternalHelper.TimedReplayCallable.get()
Methods in io.reactivex.rxjava3.internal.operators.observable that return types with arguments of type ConnectableObservableModifier and TypeMethodDescriptionstatic <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, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) static <T> Supplier
<ConnectableObservable<T>> ObservableInternalHelper.replaySupplier
(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ConnectableObservableModifier and TypeMethodDescriptionstatic <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 ConnectableObservableModifierConstructorDescriptionObservableAutoConnect
(ConnectableObservable<? extends T> source, int numberOfObservers, Consumer<? super Disposable> connection) ObservableRefCount
(ConnectableObservable<T> source) ObservableRefCount
(ConnectableObservable<T> source, int n, long timeout, TimeUnit unit, Scheduler scheduler) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ConnectableObservableModifierConstructorDescription(package private)
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 ConnectableObservableModifier and TypeFieldDescription(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 ConnectableObservableModifier and TypeMethodDescriptionstatic <@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 ConnectableObservableModifier and TypeMethodDescriptionstatic @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 ConnectableObservableModifier and TypeMethodDescriptionstatic <@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 ConnectableObservableModifier and TypeMethodDescriptionstatic 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.