Function use

packages/core/sdk/src/fuma-runtime.ts:358–361

(label, fn)

  const rebind = (handle: FumaDb): FumaDb =>
    options.context === undefined ? handle : withQueryContext(handle, options.context);
  const use: IFumaClient["use"] = (label, fn) =>
    Effect.flatMap(Effect.service(activeFumaDbRef), (active) =>
      fumaEffect(label, () => fn(makeSafeFumaQuery(rebind(active ?? db), options))),
    ).pipe(Effect.withSpan(`fumadb.${label}`));

  const transaction = <A, E>(effect: Effect.Effect<A, E>): Effect.Effect<A, E | StorageFailure> =>
    Effect.flatMap(Effect.service(activeFumaDbRef), (active) => {