( self: StatementPrimitive<A>, span: Tracer.Span, f: (statement: StatementPrimitive<A>) => Effect.Effect<X, E, R> )
| 65 | ) => Layer.locallyScoped(currentTransformer, Option.some(f)) |
| 66 | |
| 67 | const withStatement = <A, X, E, R>( |
| 68 | self: StatementPrimitive<A>, |
| 69 | span: Tracer.Span, |
| 70 | f: (statement: StatementPrimitive<A>) => Effect.Effect<X, E, R> |
| 71 | ) => |
| 72 | Effect.withFiberRuntime<X, E, R>((fiber) => { |
| 73 | const transform = fiber.getFiberRef(currentTransformer) |
| 74 | if (transform._tag === "None") { |
| 75 | return f(self) |
| 76 | } |
| 77 | return Effect.flatMap( |
| 78 | transform.value( |
| 79 | self, |
| 80 | make(self.acquirer, self.compiler, self.spanAttributes, self.transformRows), |
| 81 | fiber.getFiberRefs(), |
| 82 | span |
| 83 | ) as Effect.Effect< |
| 84 | StatementPrimitive<A> |
| 85 | >, |
| 86 | f |
| 87 | ) |
| 88 | }) |
| 89 | |
| 90 | /** @internal */ |
| 91 | export class StatementPrimitive<A> extends Effectable.Class<ReadonlyArray<A>, Error.SqlError> |
no test coverage detected
searching dependent graphs…