PagingRx

public final class PagingRx


Summary

Public fields

final @NonNull Flowable<@NonNull PagingData<@NonNull Value>>

A Flowable of PagingData, which mirrors the stream provided by Pager.flow, but exposes it as a Flowable.

final @NonNull Observable<@NonNull PagingData<@NonNull Value>>

An Observable of PagingData, which mirrors the stream provided by Pager.flow, but exposes it as an Observable.

Public constructors

Public methods

static final @ExperimentalCoroutinesApi @NonNull Observable<@NonNull PagingData<@NonNull T>>
<T extends Object> PagingRx.cachedIn(
    Observable<PagingData<T>> receiver,
    CoroutineScope scope
)

Operator which caches an Observable of PagingData within a CoroutineScope.

static final @ExperimentalCoroutinesApi @NonNull Flowable<@NonNull PagingData<@NonNull T>>
<T extends Object> PagingRx.cachedIn(
    Flowable<PagingData<T>> receiver,
    CoroutineScope scope
)

Operator which caches a Flowable of PagingData within a CoroutineScope.

static final @NonNull PagingData<@NonNull T>
<T extends Object> PagingRx.filter(
    PagingData<T> receiver,
    Function1<T, Single<Boolean>> predicate
)

Returns a PagingData containing only elements matching the given predicate.

static final @NonNull PagingData<@NonNull R>
<T extends Object, R extends Object> PagingRx.flatMap(
    PagingData<T> receiver,
    Function1<T, Single<Iterable<R>>> transform
)

Returns a