T - the source element typeK - the key typeV - the value typeD - the duration element type, ignoredpublic static final class GroupByUntil.WithComparer<K,V,T,D> extends java.lang.Object implements Observable<GroupedObservable<K,V>>
Exception semantics: if the source throws an exception, all active groups will receive the exception followed by the outer observer of the groups.
Completion semantics: if the source finishes, all active groups will receive a finish signal followed by the outer observer.
| Constructor and Description |
|---|
WithComparer(Observable<? extends T> source,
Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector,
Func1<? super GroupedObservable<K,V>,? extends Observable<D>> durationSelector,
Func2<? super K,? super K,java.lang.Boolean> keyComparer)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.io.Closeable |
register(Observer<? super GroupedObservable<K,V>> observer)
Registers an observer for the notification of Ts.
|
public WithComparer(Observable<? extends T> source, Func1<? super T,? extends K> keySelector, Func1<? super T,? extends V> valueSelector, Func1<? super GroupedObservable<K,V>,? extends Observable<D>> durationSelector, Func2<? super K,? super K,java.lang.Boolean> keyComparer)
source - the source of TskeySelector - the key extractorvalueSelector - the value extractordurationSelector - the observable for a particular group terminationkeyComparer - the key comparer for the grouping@Nonnull
public java.io.Closeable register(@Nonnull
Observer<? super GroupedObservable<K,V>> observer)
Observableregister in interface Observable<GroupedObservable<K,V>>observer - the observer of Ts or any supertype of it