core/io.neuralheads.kmpworker.core/progressUpdates

progressUpdates

fun Flow<TaskState>.progressUpdates(): Flow<TaskState.Running>

Filters to only TaskState.Running states that carry progress info.