Package io.reactivex.rxjava3.flowables
Classes supporting the Flowable base reactive class:
ConnectableFlowable
and
GroupedFlowable
.-
Class Summary Class Description ConnectableFlowable<T> AConnectableFlowable
resembles an ordinaryFlowable
, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableFlowable.connect(io.reactivex.rxjava3.functions.Consumer<? super io.reactivex.rxjava3.disposables.Disposable>)
method is called.GroupedFlowable<K,T> AFlowable
that has been grouped by key, the value of which can be obtained withGroupedFlowable.getKey()
.