(request: R)
| 512 | } |
| 513 | |
| 514 | const requestContext = <R extends Machine.Public<M>>(request: R) => |
| 515 | Effect.sync(() => { |
| 516 | const fiber = Option.getOrThrow(Fiber.getCurrentFiber()) |
| 517 | const fiberRefs = fiber.getFiberRefs() |
| 518 | const context = FiberRefs.getOrDefault(fiberRefs, FiberRef.currentContext) |
| 519 | |
| 520 | const deferred = Deferred.unsafeMake<Request.Success<R>, Request.Error<R>>(fiber.id()) |
| 521 | const span: Tracer.AnySpan | undefined = context.unsafeMap.get(Tracer.ParentSpan.key) |
| 522 | const addSpans = FiberRefs.getOrDefault(fiberRefs, currentTracingEnabled) |
| 523 | |
| 524 | return [request, deferred, span, addSpans] as const |
| 525 | }) |
| 526 | |
| 527 | const send = <R extends Machine.Public<M>>(request: R) => |
| 528 | Effect.flatMap( |
no test coverage detected