Package io.reactivex.rxjava3.observables
Classes supporting the Observable base reactive class:
ConnectableObservable
and
GroupedObservable
.-
Class Summary Class Description ConnectableObservable<T> AConnectableObservable
resembles 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> AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.