Function executeAcquire

packages/platform/src/internal/worker.ts:151–184

(request: I, makeMailbox: Effect.Effect<Q>)

          })

        const executeAcquire = <
          Q extends Mailbox.Mailbox<O, E | WorkerError> | Deferred.Deferred<O, E | WorkerError>
        >(request: I, makeMailbox: Effect.Effect<Q>) =>
          Effect.withFiberRuntime<{
            readonly id: number
            readonly mailbox: Q
          }>((fiber) => {
            const context = fiber.getFiberRef(FiberRef.currentContext)
            const span = Context.getOption(context, Tracer.ParentSpan).pipe(
              Option.filter((span): span is Tracer.Span => span._tag === "Span")
            )
            const id = requestIdCounter++
            return makeMailbox.pipe(
              Effect.tap((mailbox) => {
                requestMap.set(id, mailbox)
                return wrappedEncode(request).pipe(
                  Effect.tap((payload) =>
                    backing.send([
                      id,
                      0,
                      payload,
                      span._tag === "Some" ? [span.value.traceId, span.value.spanId, span.value.sampled] : undefined
                    ], collector.unsafeRead())
                  ),
                  Effect.catchAllCause((cause) =>
                    Mailbox.isMailbox<O, E | WorkerError>(mailbox)
                      ? mailbox.failCause(cause)
                      : Deferred.failCause(mailbox, cause)
                  )
                )
              }),
              Effect.map((mailbox) => ({ id, mailbox }))
            )
          })

        const executeRelease = ({ id }: { readonly id: number }, exit: Exit.Exit<unknown, unknown>) => {
          const release = Effect.sync(() => requestMap.delete(id))