Function handlePort

packages/platform-browser/src/internal/workerRunner.ts:91–116

(port: MessagePort)

          )
        }
        function handlePort(port: MessagePort) {
          const fiber = Scope.fork(scope, ExecStrategy.sequential).pipe(
            Effect.flatMap((scope) => {
              const portId = currentPortId++
              ports.set(portId, [port, scope])
              const onMsg = onMessage(portId)
              port.addEventListener("message", onMsg)
              port.addEventListener("messageerror", onMessageError)
              if ("start" in port) {
                port.start()
              }
              port.postMessage([0])
              return Scope.addFinalizer(
                scope,
                Effect.sync(() => {
                  port.removeEventListener("message", onMsg)
                  port.removeEventListener("messageerror", onError)
                  port.close()
                })
              )
            }),
            runFork
          )
          fiber.addObserver(onExit)
          FiberSet.unsafeAdd(fiberSet, fiber)
        }
        self.addEventListener("error", onError)
        let prevOnConnect: unknown | undefined
        if ("onconnect" in self) {