workflow-rx2/com.squareup.workflow1.rx2/PublisherWorker/run

run

override fun run(): Flow<OutputT>(source)