MCPcopy
hub / github.com/Effect-TS/effect / withStatement

Function withStatement

packages/sql/src/internal/statement.ts:67–88  ·  view source on GitHub ↗
(
  self: StatementPrimitive<A>,
  span: Tracer.Span,
  f: (statement: StatementPrimitive<A>) => Effect.Effect<X, E, R>
)

Source from the content-addressed store, hash-verified

65) => Layer.locallyScoped(currentTransformer, Option.some(f))
66
67const 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 */
91export class StatementPrimitive<A> extends Effectable.Class<ReadonlyArray<A>, Error.SqlError>

Callers 2

withConnectionMethod · 0.85
streamMethod · 0.85

Calls 5

makeFunction · 0.70
getFiberRefMethod · 0.65
getFiberRefsMethod · 0.65
fFunction · 0.50
valueMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…