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
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
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 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.@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.@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
.@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.@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.@NonNull ConnectableFlowable<T>
Flowable. replay(int bufferSize, long time, @NonNull java.util.concurrent.TimeUnit unit)
Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays at mostbufferSize
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 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.@NonNull ConnectableFlowable<T>
Flowable. replay(int bufferSize, long time, @NonNull java.util.concurrent.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.@NonNull ConnectableFlowable<T>
Flowable. replay(long time, @NonNull java.util.concurrent.TimeUnit unit)
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.@NonNull ConnectableFlowable<T>
Flowable. replay(long time, @NonNull java.util.concurrent.TimeUnit unit, @NonNull Scheduler scheduler)
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.@NonNull ConnectableFlowable<T>
Flowable. replay(long time, @NonNull java.util.concurrent.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.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 sourceFlowable
.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.
-