Skip to content

//workflow/com.squareup.workflow1.rx2

Package com.squareup.workflow1.rx2

Types

Name Summary
PublisherWorker [jvm]
Content
abstract class PublisherWorkerOutputT : Any> : Worker<OutputT>
More info
An convenience implementation of Worker that is expressed in terms of Reactive Streams’ Publisher instead of Flow.


Functions

Name Summary
asWorker [jvm]
Content
fun Completable.asWorker(): Worker<Nothing>
More info
Creates a Worker from this Completable.


[jvm]
Content
inline fun <T : Any> MaybeT?>.asWorker(): Worker<T>
More info
Creates a Worker from this Maybe.


[jvm]
Content
inline fun <T : Any> ObservableT?>.asWorker(): Worker<T>
More info
Creates a Worker from this Observable.


[jvm]
Content
inline fun <T : Any> SingleT?>.asWorker(): Worker<T>
More info
Creates a Worker from this Single.


[jvm]
Content
inline fun <T : Any> PublisherT?>.asWorker(): Worker<T>
More info
Creates a Worker from this Publisher (Flowable is a Publisher).