runPublisher

Returns a Flowable to execute the work represented by this worker.

If you have an io.reactivex.Observable instead, just call toFlowable to convert it.

The Flowable is subscribed to in the context of the workflow runtime. When this Worker, its parent Workflow, or any ancestor Workflows are torn down, the subscription will be disposed.