(u: unknown)
| 579 | ) |
| 580 | |
| 581 | const sendUnknown = (u: unknown) => |
| 582 | Effect.suspend(() => |
| 583 | runState.decodeRequest(u).pipe( |
| 584 | Effect.flatMap((req) => |
| 585 | Effect.flatMap( |
| 586 | Effect.exit(send(req)), |
| 587 | (exit) => Schema.serializeExit(req, exit) |
| 588 | ) |
| 589 | ), |
| 590 | Effect.provide(context) |
| 591 | ) |
| 592 | ) as Effect.Effect<Schema.ExitEncoded<unknown, unknown, unknown>, ParseResult.ParseError> |
| 593 | |
| 594 | const publishState = (newState: Machine.State<M>) => { |
| 595 | if (currentState !== newState) { |