PublisherWorker¶

[jvm] abstract class PublisherWorkerOutputT : Any> : Worker<OutputT>

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

If you’re using RxJava, Flowable is a Publisher.

Subclassing this is equivalent to just implementing Worker.run directly and calling asFlow on your Publisher.

Constructors¶


PublisherWorker	[jvm] fun PublisherWorker()

Name	Summary
doesSameWorkAs	[jvm] Content open fun doesSameWorkAs(otherWorker: Worker<*>): Boolean
run	[jvm] Content override fun run(): Flow<OutputT>
runPublisher	[jvm] Content abstract fun runPublisher(): PublisherOutputT> More info Returns a Flowable to execute the work represented by this worker.