replayAll

open suspend override fun replayAll(emit: suspend (taskId: String, state: TaskState) -> Unit)