Package io.reactivex.rxjava3.observables
Classes supporting the Observable base reactive class:
ConnectableObservable and
GroupedObservable.-
Class Summary Class Description ConnectableObservable<T> AConnectableObservableresembles an ordinaryObservable, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect(io.reactivex.rxjava3.functions.Consumer<? super io.reactivex.rxjava3.disposables.Disposable>)method is called.GroupedObservable<K,T> AnObservablethat has been grouped by key, the value of which can be obtained withGroupedObservable.getKey().