public abstract Class GroupedObservable<K, T>

Class Inheritance

extends Observable<T>

java.lang.Object
io.reactivex.Observable
io.reactivex.observables.GroupedObservable

Known Direct Subclasses

io.reactivex.internal.operators.observable.ObservableGroupBy.GroupedUnicast

Type Parameters

<K>: the type of the key
<T>: the type of the items emitted by the GroupedObservable

Imports

io.reactivex.Observable, io.reactivex.annotations.Nullable

An Observable that has been grouped by key, the value of which can be obtained with getKey().

Note

A GroupedObservable will cache the items it is to emit until such time as it is subscribed to. For this reason, in order to avoid memory leaks, you should not simply ignore those GroupedObservables that do not concern you. Instead, you can signal to them that they may discard their buffers by applying an operator like take(0) to them.

See Also: Observable#groupBy(io.reactivex.functions.Function), ReactiveX documentation: GroupBy

Field Summary

Modifier and Type	Field and Description
pack-priv final K	key

Constructor Summary

Access	Constructor and Description
protected	GroupedObservable(K the key key) Constructs a GroupedObservable with the given key.

Method Summary

Modifier and Type	Method and Description
public K	Returns: the key that the items emitted by this `GroupedObservable` were grouped by getKey() Returns the key that identifies the group of items emitted by this `GroupedObservable`.

Inherited from io.reactivex.Observable:: all amb ambArray ambWith any as blockingFirst blockingFirst blockingForEach blockingIterable blockingIterable blockingLast blockingLast blockingLatest blockingMostRecent blockingNext blockingSingle blockingSingle blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer buffer bufferSize cache cacheWithInitialCapacity cast collect collectInto combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatest combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError combineLatestDelayError compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatArrayEager concatArrayEagerDelayError concatArrayEagerDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatMap concatMap concatMapCompletable concatMapCompletable concatMapCompletableDelayError concatMapCompletableDelayError concatMapCompletableDelayError concatMapDelayError concatMapDelayError concatMapEager concatMapEager concatMapEagerDelayError concatMapEagerDelayError concatMapIterable concatMapIterable concatMapMaybe concatMapMaybe concatMapMaybeDelayError concatMapMaybeDelayError concatMapMaybeDelayError concatMapSingle concatMapSingle concatMapSingleDelayError concatMapSingleDelayError concatMapSingleDelayError concatWith concatWith concatWith concatWith contains count create debounce debounce debounce defaultIfEmpty defer delay delay delay delay delay delay delaySubscription delaySubscription delaySubscription dematerialize dematerialize distinct distinct distinct distinctUntilChanged distinctUntilChanged distinctUntilChanged doAfterNext doAfterTerminate doFinally doOnComplete doOnDispose doOnEach doOnEach doOnError doOnLifecycle doOnNext doOnSubscribe doOnTerminate elementAt elementAt elementAtOrError empty error error filter first firstElement firstOrError flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMap flatMapCompletable flatMapCompletable flatMapIterable flatMapIterable flatMapMaybe flatMapMaybe flatMapSingle flatMapSingle forEach forEachWhile forEachWhile forEachWhile fromArray fromCallable fromFuture fromFuture fromFuture fromFuture fromIterable fromPublisher generate generate generate generate generate groupBy groupBy groupBy groupBy groupBy groupJoin hide ignoreElements interval interval interval interval intervalRange intervalRange isEmpty join just just just just just just just just just just last lastElement lastOrError lift map materialize merge merge merge merge merge merge merge merge mergeArray mergeArray mergeArrayDelayError mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith mergeWith mergeWith mergeWith never observeOn observeOn observeOn ofType onErrorResumeNext onErrorResumeNext onErrorReturn onErrorReturnItem onExceptionResumeNext onTerminateDetach publish publish range rangeLong reduce reduce reduceWith repeat repeat repeatUntil repeatWhen replay replay replay replay replay replay replay replay replay replay replay replay replay replay replay replay retry retry retry retry retry retryUntil retryWhen safeSubscribe sample sample sample sample sample sample scan scan scanWith sequenceEqual sequenceEqual sequenceEqual sequenceEqual serialize share single singleElement singleOrError skip skip skip skipLast skipLast skipLast skipLast skipLast skipLast skipUntil skipWhile sorted sorted startWith startWith startWith startWithArray subscribe subscribe subscribe subscribe subscribe subscribe subscribeActual subscribeOn subscribeWith switchIfEmpty switchMap switchMap switchMapCompletable switchMapCompletableDelayError switchMapDelayError switchMapDelayError switchMapMaybe switchMapMaybeDelayError switchMapSingle switchMapSingleDelayError switchOnNext switchOnNext switchOnNextDelayError switchOnNextDelayError take take take takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeLast takeUntil takeUntil takeWhile test test throttleFirst throttleFirst throttleLast throttleLast throttleLatest throttleLatest throttleLatest throttleLatest throttleWithTimeout throttleWithTimeout timeInterval timeInterval timeInterval timeInterval timeout timeout timeout timeout timeout timeout timeout timeout timer timer timestamp timestamp timestamp timestamp to toFlowable toFuture toList toList toList toMap toMap toMap toMultimap toMultimap toMultimap toMultimap toSortedList toSortedList toSortedList toSortedList unsafeCreate unsubscribeOn using using window window window window window window window window window window window window window window window window window window window withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom withLatestFrom wrap zip zip zip zip zip zip zip zip zip zip zip zip zipArray zipIterable zipWith zipWith zipWith zipWith

Field Detail

key	back to summary
pack-priv final K key

Constructor Detail

GroupedObservable	back to summary
protected GroupedObservable(K key) Constructs a GroupedObservable with the given key. Parameters key:K the key

GroupedObservable

back to summary

protected GroupedObservable(K key)

Constructs a GroupedObservable with the given key.

Parameters

key:K: the key

Method Detail

getKey back to summary

getKey	back to summary
public K getKey() Returns the key that identifies the group of items emitted by this `GroupedObservable`. Returns:K the key that the items emitted by this `GroupedObservable` were grouped by Annotations @Nullable

public K getKey()

Returns the key that identifies the group of items emitted by this GroupedObservable.

Returns:K

the key that the items emitted by this GroupedObservable were grouped by

Annotations

@Nullable