(handler, options_)
| 74 | }): Worker<any, any> => ({ |
| 75 | send: options.send, |
| 76 | run(handler, options_) { |
| 77 | const onSpawn = options_?.onSpawn ?? Effect.void |
| 78 | return options.run((msg) => { |
| 79 | if (msg[0] === 0) return onSpawn |
| 80 | return handler(msg[1]) |
| 81 | }) |
| 82 | } |
| 83 | }) |
| 84 | |
| 85 | /** |