Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
Modifier and Type | Method and Description |
---|---|
<R> Single<R> |
Single.cast(Class<R> klass)
Casts the success value of the current Single into the target type or signals a
ClassCastException if not compatible.
|
<K,R> Observable<GroupedObservable<K,R>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends R> elementSelector,
int bufferSize,
boolean delayError,
Func1<Action1<Object>,Map<K,Object>> evictingMapFactory)
Groups the items emitted by an
Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
Single<T> |
Single.unsubscribeOn(Scheduler scheduler)
Returns a Single which makes sure when a subscriber cancels the subscription,
the dispose is called on the specified scheduler
|
Copyright © 2018. All rights reserved.