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
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
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 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.@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
.@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
.@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
.@NonNull ConnectableObservable<T>
Observable. replay(int bufferSize, long time, @NonNull java.util.concurrent.TimeUnit unit)
Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays at mostbufferSize
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 aConnectableObservable
that shares a single subscription to the currentObservable
and that replays a maximum ofbufferSize
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 aConnectableObservable
that shares a single subscription to the currentObservable
and that replays a maximum ofbufferSize
items that are emitted within a specified time window.@NonNull ConnectableObservable<T>
Observable. replay(long time, @NonNull java.util.concurrent.TimeUnit unit)
Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window.@NonNull ConnectableObservable<T>
Observable. replay(long time, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler)
Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window.@NonNull ConnectableObservable<T>
Observable. replay(long time, @NonNull java.util.concurrent.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.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.
-