workflow-rx2/com.squareup.workflow1.rx2

Package-level declarations

Types

Link copied to clipboard
abstract class PublisherWorker<out OutputT : Any> : Worker<OutputT>

An convenience implementation of Worker that is expressed in terms of Reactive Streams' Publisher instead of Flow.

Functions

Link copied to clipboard
fun Completable.asWorker(): Worker<Nothing>

Creates a Worker from this Completable.

inline fun <T : Any> Maybe<out T?>.asWorker(): Worker<T>

Creates a Worker from this Maybe.

inline fun <T : Any> Observable<out T?>.asWorker(): Worker<T>

Creates a Worker from this Observable.

inline fun <T : Any> Single<out T?>.asWorker(): Worker<T>

Creates a Worker from this Single.

inline fun <T : Any> Publisher<out T?>.asWorker(): Worker<T>

Creates a Worker from this Publisher (Flowable is a Publisher).