Package io.reactivex.rxjava3.flowables
package io.reactivex.rxjava3.flowables
Classes supporting the Flowable base reactive class:
ConnectableFlowable and
GroupedFlowable.-
ClassesClassDescriptionA
ConnectableFlowableresembles 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> AFlowablethat has been grouped by key, the value of which can be obtained withGroupedFlowable.getKey().