core/io.neuralheads.kmpworker.core/onRunning

onRunning

fun Flow<TaskState>.onRunning(action: suspend () -> Unit): Flow<TaskState>

Invokes action whenever the task enters TaskState.Running.