Uses of Class
io.reactivex.rxjava3.flowables.ConnectableFlowable
Packages that use ConnectableFlowable
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 ConnectableFlowable in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return ConnectableFlowableModifier and TypeMethodDescriptionfinal @NonNull ConnectableFlowable
<T> Flowable.publish()
Returns aConnectableFlowable
, which is a variety ofPublisher
that waits until itsconnect
method is called before it begins emitting items to thoseSubscriber
s that have subscribed to it.final @NonNull ConnectableFlowable
<T> Flowable.publish
(int bufferSize) Returns aConnectableFlowable
, which is a variety ofPublisher
that waits until itsconnect
method is called before it begins emitting items to thoseSubscriber
s that have subscribed to it.final @NonNull ConnectableFlowable
<T> Flowable.replay()
Returns aConnectableFlowable
that shares a single subscription to the underlyingPublisher
that will replay all of its items and notifications to any futureSubscriber
.final @NonNull ConnectableFlowable
<T> Flowable.replay
(int bufferSize) Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays at mostbufferSize
items to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Flowable.replay
(int bufferSize, boolean eagerTruncate) Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays at mostbufferSize
items to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays at mostbufferSize
items that were emitted during a specified time window.final @NonNull ConnectableFlowable
<T> Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays a maximum ofbufferSize
items that are emitted within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Flowable.replay
(int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays a maximum ofbufferSize
items that are emitted within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays all items emitted by it within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays all items emitted by it within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Flowable.replay
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays all items emitted by it within a specified time window to lateSubscriber
s. -
Uses of ConnectableFlowable in io.reactivex.rxjava3.internal.operators.flowable
Subclasses of ConnectableFlowable in io.reactivex.rxjava3.internal.operators.flowableModifier and TypeClassDescriptionfinal class
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
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ConnectableFlowableModifier and TypeFieldDescription(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 ConnectableFlowableModifier and TypeFieldDescriptionprivate final Supplier
<? extends ConnectableFlowable<U>> FlowableReplay.MulticastFlowable.connectableFactory
Methods in io.reactivex.rxjava3.internal.operators.flowable that return ConnectableFlowableModifier and TypeMethodDescriptionstatic <T> ConnectableFlowable
<T> 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 sourceFlowable
.static <T> ConnectableFlowable
<T> FlowableReplay.createFrom
(Flowable<? extends T> source) Creates a replaying ConnectableObservable with an unbounded buffer.FlowableInternalHelper.BufferedReplaySupplier.get()
FlowableInternalHelper.BufferedTimedReplay.get()
FlowableInternalHelper.ReplaySupplier.get()
FlowableInternalHelper.TimedReplay.get()
Methods in io.reactivex.rxjava3.internal.operators.flowable that return types with arguments of type ConnectableFlowableModifier and TypeMethodDescriptionstatic <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 ConnectableFlowableModifier and TypeMethodDescriptionstatic <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 ConnectableFlowableModifierConstructorDescriptionFlowableAutoConnect
(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 ConnectableFlowableModifierConstructorDescription(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 ConnectableFlowableModifier and TypeFieldDescription(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 ConnectableFlowableModifier and TypeMethodDescriptionstatic <@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 ConnectableFlowableModifier and TypeMethodDescriptionstatic @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 ConnectableFlowableModifier and TypeMethodDescriptionstatic <@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 ConnectableFlowableModifier and TypeMethodDescriptionstatic 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.