ios/io.neuralheads.kmpworker.ios/TaskStateObserver

TaskStateObserver

class TaskStateObserver(flow: Flow<TaskState>)

Convenience factory for creating a FlowWrapper from TaskState Flows.

let observer = TaskStateObserver(worker: kmpWorker, taskId: "sync")
observer.onStateChange { state in
    if state is TaskState.Success { print("Done!") }
}

Constructors

TaskStateObserver

constructor(flow: Flow<TaskState>)

Functions

onStateChange

fun onStateChange(callback: (TaskState) -> Unit)

Observes state changes.

stop

fun stop()

Stops observing.