core/io.neuralheads.kmpworker.core/onTerminal

onTerminal

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

Invokes action when the task reaches any terminal state.