(newState: Machine.State<M>)
| 592 | ) as Effect.Effect<Schema.ExitEncoded<unknown, unknown, unknown>, ParseResult.ParseError> |
| 593 | |
| 594 | const publishState = (newState: Machine.State<M>) => { |
| 595 | if (currentState !== newState) { |
| 596 | currentState = newState |
| 597 | return PubSub.publish(pubsub, newState) |
| 598 | } |
| 599 | return Effect.void |
| 600 | } |
| 601 | |
| 602 | const run = Effect.gen(function*() { |
| 603 | const fiberSet = yield* FiberSet.make<any, MachineDefect>() |