Function onMessage

packages/platform-browser/src/internal/workerRunner.ts:56–78

(portId: number)

        }

        function onMessage(portId: number) {
          return function(event: MessageEvent) {
            const message = event.data as Runner.BackingRunner.Message<I>
            if (message[0] === 0) {
              const result = handler(portId, message[1])
              if (Effect.isEffect(result)) {
                const fiber = runFork(result)
                fiber.addObserver(onExit)
                FiberSet.unsafeAdd(fiberSet, fiber)
              }
            } else {
              const port = ports.get(portId)
              if (!port) {
                return
              } else if (ports.size === 1) {
                // let the last port close with the outer scope
                return Deferred.unsafeDone(closeLatch, Exit.void)
              }
              ports.delete(portId)
              Effect.runFork(Scope.close(port[1], Exit.void))
            }
          }
        }
        function onMessageError(error: MessageEvent) {
          Deferred.unsafeDone(
            closeLatch,