core/io.neuralheads.kmpworker.core/onFailed

onFailed

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

Invokes action when the task reaches TaskState.Failed.