Core/com.zappstudio.zappbase.app.ext.rx

Package-level declarations

Types

Link copied to clipboard

Properties

Link copied to clipboard

Functions

Link copied to clipboard
fun <T, R> Maybe<T>.mapToNullable(function: (T) -> R?): Maybe<R>
fun <T, R> Single<T>.mapToNullable(function: (T) -> R?): Maybe<R>
Link copied to clipboard
fun Completable.toLiveData(): SingleLiveEvent<ResultEvent>
fun <T> Maybe<T>.toLiveData(): SingleLiveEvent<T>
fun <T> Single<T>.toLiveData(): SingleLiveEvent<T>
fun <T> Publisher<T>.toLiveData(resubscribe: Boolean, stopOn: Lifecycle.Event = Lifecycle.Event.ON_DESTROY): LiveData<T>
fun <T> Observable<T>.toLiveData(resubscribe: Boolean, stopOn: Lifecycle.Event = Lifecycle.Event.ON_DESTROY, backpressureStrategy: BackpressureStrategy = BackpressureStrategy.BUFFER): LiveData<T>
Link copied to clipboard
fun Completable.toResult(scheduler: Scheduler = schedulerProvider.io()): Single<ResultEvent>
fun <T : Any> Flowable<T>.toResult(scheduler: Scheduler = schedulerProvider.io()): Flowable<ResultObject<T>>
fun <T> Maybe<T>.toResult(scheduler: Scheduler = schedulerProvider.io()): Maybe<ResultObject<T & Any>>
fun <T> Observable<T>.toResult(scheduler: Scheduler = schedulerProvider.io()): Observable<ResultObject<T & Any>>
fun <T> Single<T>.toResult(scheduler: Scheduler = schedulerProvider.io()): Single<ResultObject<T & Any>>