square / workflow-swift

A Swift and Kotlin library for making composable state machines, and UIs driven by those state machines.
https://square.github.io/workflow
Apache License 2.0
326 stars 44 forks source link

Workflow host observers are notified before internal updates are finished #289

Open bolderkat opened 3 months ago

bolderkat commented 3 months ago

Scenario

Say I am hosting a Workflow in a UIViewController using a WorkflowHostingController. In the view controller, I am observing the output of my Workflow with something like:

hostingController.output.take(during: lifetime).observeValues { [weak self] output in
    guard let self else { return }

    switch output {
    case .somethingChanged(let foo):
        self.foo = foo
    }
}

If I need to pass the new value of foo back into the Workflow, and I try to update the Workflow synchronously, e.g. by calling:

hostingController.update(workflow: MyWorkflow(foo: foo))

then this consistently results in a crash: Fatal error: EventPipe can only be enabled from the `pending` state

A suggestion by @jamieQ is that "we could potentially delay notifying the workflow host observers until after all the internal updates were finished."

Workarounds

We can avoid the crash by delaying event handling, either when observing the Workflow output:

hostingController.output.take(during: lifetime).observe(on: QueueScheduler.main).observeValues {
    // ...
}

or when updating the Workflow:

DispatchQueue.main.async { [weak self] in
    guard let self else { return }
    self.hostingController.update(workflow: MyWorkflow(foo: foo))
}