@effect/query - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

DataSource.js

@@ -12,2 +12,6 @@ "use strict";
  * @since 1.0.0
+ */
+
+/**
+ * @since 1.0.0
  * @category symbols
@@ -14,0 +18,0 @@ */

internal/cache.js

@@ -28,6 +28,6 @@ "use strict";
   get(request) {
-    return Debug.bodyWithTrace(trace => (0, _Function.pipe)(Effect.map(Ref.get(this.state), state => HashMap.get(state, request)), Effect.some, Effect.orElseFail(_Function.constVoid)).traced(trace));
+    return Debug.bodyWithTrace(trace => Effect.orElseFail(_Function.constVoid)(Effect.some(Effect.map(Ref.get(this.state), state => HashMap.get(state, request)))).traced(trace));
   }
   lookup(request) {
-    return Debug.bodyWithTrace(trace => Effect.flatMap(Ref.make(Option.none()), ref => Ref.modify(this.state, state => (0, _Function.pipe)(HashMap.get(state, request), Option.match(() => [Either.left(ref), HashMap.set(state, request, ref)], ref => [Either.right(ref), state])))).traced(trace));
+    return Debug.bodyWithTrace(trace => Effect.flatMap(Ref.make(Option.none()), ref => Ref.modify(this.state, state => Option.match(() => [Either.left(ref), HashMap.set(state, request, ref)], ref => [Either.right(ref), state])(HashMap.get(state, request)))).traced(trace));
   }
@@ -34,0 +34,0 @@ set(request, result) {

internal/completedRequestMap.js

@@ -9,3 +9,2 @@ "use strict";
 var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Either"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
@@ -64,5 +63,5 @@ var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Context"));
 const setOption = /*#__PURE__*/Debug.dual(3, (self, request, result) => {
-  (0, _Function.pipe)(result, Either.match(e => set(self, request, Either.left(e)), Option.match(() => self, a => set(self, request, Either.right(a)))));
+  Either.match(e => set(self, request, Either.left(e)), Option.match(() => self, a => set(self, request, Either.right(a))))(result);
 });
 exports.setOption = setOption;
 //# sourceMappingURL=completedRequestMap.js.map

internal/dataSource.js

@@ -13,3 +13,2 @@ "use strict";
 var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Either"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
@@ -59,3 +58,3 @@ var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
   const innerMap = completedRequestMap.empty();
-  return (0, _Function.pipe)(restore(run)(newRequests), Effect.provideService(completedRequestMap.Tag, innerMap), Effect.map(() => completedRequestMap.combine(outerMap, innerMap)));
+  return Effect.map(() => completedRequestMap.combine(outerMap, innerMap))(Effect.provideService(completedRequestMap.Tag, innerMap)(restore(run)(newRequests)));
 })));
@@ -70,3 +69,3 @@ /** @internal */
 exports.batchN = batchN;
-const contramap = /*#__PURE__*/Debug.untracedDual(2, restore => (self, f) => new DataSourceImpl(`${self.identifier}.contramap(${f.description})`, requests => restore(self.runAll)((0, _Function.pipe)(requests, Chunk.map(Chunk.map(restore(f.value)))))));
+const contramap = /*#__PURE__*/Debug.untracedDual(2, restore => (self, f) => new DataSourceImpl(`${self.identifier}.contramap(${f.description})`, requests => restore(self.runAll)(Chunk.map(Chunk.map(restore(f.value)))(requests))));
 /** @internal */
@@ -80,11 +79,11 @@ exports.contramap = contramap;
 exports.contramapEffect = contramapEffect;
-const eitherWith = /*#__PURE__*/Debug.untracedDual(3, restore => (self, that, f) => new DataSourceImpl(`${self.identifier}.eitherWith(${that.identifier})(${f.description})`, batch => (0, _Function.pipe)(Effect.forEach(batch, requests => {
-  const [as, bs] = (0, _Function.pipe)(requests, Chunk.partitionMap(restore(f.value)));
+const eitherWith = /*#__PURE__*/Debug.untracedDual(3, restore => (self, that, f) => new DataSourceImpl(`${self.identifier}.eitherWith(${that.identifier})(${f.description})`, batch => Effect.map(Chunk.reduce(completedRequestMap.empty(), (acc, curr) => completedRequestMap.combine(acc, curr)))(Effect.forEach(batch, requests => {
+  const [as, bs] = Chunk.partitionMap(restore(f.value))(requests);
   return Effect.zipWithPar(restore(self.runAll)(Chunk.of(as)), restore(that.runAll)(Chunk.of(bs)), (self, that) => completedRequestMap.combine(self, that));
-}), Effect.map(Chunk.reduce(completedRequestMap.empty(), (acc, curr) => completedRequestMap.combine(acc, curr))))));
+}))));
 /** @internal */
 exports.eitherWith = eitherWith;
-const fromFunction = /*#__PURE__*/Debug.untracedMethod(restore => (name, f) => makeBatched(name, requests => Effect.serviceWith(completedRequestMap.Tag, map => (0, _Function.pipe)(requests, Chunk.forEach(request => completedRequestMap.set(map, request,
+const fromFunction = /*#__PURE__*/Debug.untracedMethod(restore => (name, f) => makeBatched(name, requests => Effect.serviceWith(completedRequestMap.Tag, map => Chunk.forEach(request => completedRequestMap.set(map, request,
 // @ts-expect-error
-Either.right(restore(f)(request))))))));
+Either.right(restore(f)(request))))(requests))));
 /** @internal */
@@ -95,3 +94,3 @@ exports.fromFunction = fromFunction;
 exports.fromFunctionBatched = fromFunctionBatched;
-const fromFunctionBatchedEffect = /*#__PURE__*/Debug.untracedMethod(restore => (name, f) => makeBatched(name, requests => Effect.serviceWith(completedRequestMap.Tag, map => (0, _Function.pipe)(Effect.match(restore(f)(requests), e => (0, _Function.pipe)(requests, Chunk.map(k => [k, Either.left(e)])), bs => (0, _Function.pipe)(requests, Chunk.zip((0, _Function.pipe)(bs, Chunk.map(Either.right))))), Effect.map(Chunk.forEach(([k, v]) => completedRequestMap.set(map, k, v)))))));
+const fromFunctionBatchedEffect = /*#__PURE__*/Debug.untracedMethod(restore => (name, f) => makeBatched(name, requests => Effect.serviceWith(completedRequestMap.Tag, map => Effect.map(Chunk.forEach(([k, v]) => completedRequestMap.set(map, k, v)))(Effect.match(restore(f)(requests), e => Chunk.map(k => [k, Either.left(e)])(requests), bs => Chunk.zip(Chunk.map(Either.right)(bs))(requests))))));
 /** @internal */
@@ -102,3 +101,3 @@ exports.fromFunctionBatchedEffect = fromFunctionBatchedEffect;
 exports.fromFunctionBatchedOption = fromFunctionBatchedOption;
-const fromFunctionBatchedOptionEffect = /*#__PURE__*/Debug.untracedMethod(restore => (name, f) => makeBatched(name, requests => Effect.serviceWithEffect(completedRequestMap.Tag, map => Effect.map(Effect.match(restore(f)(requests), e => (0, _Function.pipe)(requests, Chunk.map(k => [k, Either.left(e)])), bs => (0, _Function.pipe)(requests, Chunk.zip((0, _Function.pipe)(bs, Chunk.map(Either.right))))), Chunk.forEach(([k, v]) => completedRequestMap.setOption(map, k, v))))));
+const fromFunctionBatchedOptionEffect = /*#__PURE__*/Debug.untracedMethod(restore => (name, f) => makeBatched(name, requests => Effect.serviceWithEffect(completedRequestMap.Tag, map => Effect.map(Effect.match(restore(f)(requests), e => Chunk.map(k => [k, Either.left(e)])(requests), bs => Chunk.zip(Chunk.map(Either.right)(bs))(requests)), Chunk.forEach(([k, v]) => completedRequestMap.setOption(map, k, v))))));
 /** @internal */
@@ -109,3 +108,3 @@ exports.fromFunctionBatchedOptionEffect = fromFunctionBatchedOptionEffect;
 exports.fromFunctionBatchedWith = fromFunctionBatchedWith;
-const fromFunctionBatchedWithEffect = /*#__PURE__*/Debug.untracedMethod(restore => (name, f, g) => makeBatched(name, requests => Effect.serviceWithEffect(completedRequestMap.Tag, map => Effect.map(Effect.match(restore(f)(requests), e => (0, _Function.pipe)(requests, Chunk.map(k => [k, Either.left(e)])), bs => (0, _Function.pipe)(bs, Chunk.map(b => [restore(g)(b), Either.right(b)]))), Chunk.forEach(([k, v]) => completedRequestMap.set(map, k, v))))));
+const fromFunctionBatchedWithEffect = /*#__PURE__*/Debug.untracedMethod(restore => (name, f, g) => makeBatched(name, requests => Effect.serviceWithEffect(completedRequestMap.Tag, map => Effect.map(Effect.match(restore(f)(requests), e => Chunk.map(k => [k, Either.left(e)])(requests), bs => Chunk.map(b => [restore(g)(b), Either.right(b)])(bs)), Chunk.forEach(([k, v]) => completedRequestMap.set(map, k, v))))));
 /** @internal */
@@ -112,0 +111,0 @@ exports.fromFunctionBatchedWithEffect = fromFunctionBatchedWithEffect;

internal/parallel.js

@@ -8,3 +8,2 @@ "use strict";
 var Sequential = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/query/internal/sequential"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
@@ -53,3 +52,3 @@ var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
 exports.make = make;
-const combine = (self, that) => new ParallelImpl(HashMap.reduceWithIndex(self.map, that.map, (map, value, key) => HashMap.set(map, key, (0, _Function.pipe)(HashMap.get(map, key), Option.match(() => value, Chunk.concat(value))))));
+const combine = (self, that) => new ParallelImpl(HashMap.reduceWithIndex(self.map, that.map, (map, value, key) => HashMap.set(map, key, Option.match(() => value, Chunk.concat(value))(HashMap.get(map, key)))));
 /**
@@ -56,0 +55,0 @@ * Returns `true` if this collection of requests is empty, `false` otherwise.

internal/query.js

@@ -34,6 +34,8 @@ "use strict";
 var Duration = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Duration"));
+var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
+var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Hash"));
 var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/HashSet"));
 function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }
 function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; }
-var _a;
+var _a, _b;
 /** @internal */
@@ -52,8 +54,26 @@ const QuerySymbolKey = "@effect/query/Query";
 class QueryImpl {
-  constructor(step) {
+  constructor(step, trace) {
     this.step = step;
+    this.trace = trace;
+    this._tag = "Commit";
     this[_a] = queryVariance;
+    this[_b] = queryVariance;
   }
+  [(_a = QueryTypeId, Equal.symbol)](that) {
+    return this === that;
+  }
+  [Hash.symbol]() {
+    return Hash.random(this);
+  }
+  traced(trace) {
+    if (trace) {
+      return new QueryImpl(matchCauseQuery(this, failCause, succeed).step.traced(trace));
+    }
+    return this;
+  }
+  commit() {
+    return run(this);
+  }
 }
-_a = QueryTypeId;
+_b = Effect.EffectTypeId;
 const cachingEnabled = /*#__PURE__*/FiberRef.unsafeMake(true);
@@ -77,3 +97,3 @@ const currentCache = /*#__PURE__*/FiberRef.unsafeMake( /*#__PURE__*/cache.unsafeMake());
 exports.asUnit = asUnit;
-const cached = /*#__PURE__*/Debug.untracedMethod(() => self => (0, _Function.pipe)(fromEffect(FiberRef.getAndSet(cachingEnabled, true)), flatMap(previous => ensuring(self, fromEffect(FiberRef.set(cachingEnabled, previous))))));
+const cached = /*#__PURE__*/Debug.untracedMethod(() => self => flatMap(previous => ensuring(self, fromEffect(FiberRef.set(cachingEnabled, previous))))(fromEffect(FiberRef.getAndSet(cachingEnabled, true))));
 /** @internal */
@@ -164,3 +184,3 @@ exports.cached = cached;
     } else {
-      result = zipWith(result, restore(f)(next.value), (chunk, a) => (0, _Function.pipe)(chunk, Chunk.append(a)));
+      result = zipWith(result, restore(f)(next.value), (chunk, a) => Chunk.append(a)(chunk));
     }
@@ -180,3 +200,3 @@ }
     } else {
-      result = zipWithBatched(result, restore(f)(next.value), (chunk, a) => (0, _Function.pipe)(chunk, Chunk.append(a)));
+      result = zipWithBatched(result, restore(f)(next.value), (chunk, a) => Chunk.append(a)(chunk));
     }
@@ -194,3 +214,3 @@ }
   if (Chunk.size(chunk) === 1) {
-    return map(restore(f)((0, _Function.pipe)(chunk, Chunk.unsafeGet(0))), Chunk.of);
+    return map(restore(f)(Chunk.unsafeGet(0)(chunk)), Chunk.of);
   }
@@ -258,3 +278,3 @@ return new QueryImpl(Effect.map(Effect.forEachPar(chunk, a => restore(f)(a).step), collectAllParResult));
 exports.matchCauseQuery = matchCauseQuery;
-const matchQuery = /*#__PURE__*/Debug.untracedDual(3, restore => (self, onFailure, onSuccess) => matchCauseQuery(self, cause => (0, _Function.pipe)(Cause.failureOrCause(cause), Either.match(restore(onFailure), a => failCause(a))), restore(onSuccess)));
+const matchQuery = /*#__PURE__*/Debug.untracedDual(3, restore => (self, onFailure, onSuccess) => matchCauseQuery(self, cause => Either.match(restore(onFailure), a => failCause(a))(Cause.failureOrCause(cause)), restore(onSuccess)));
 /** @internal */
@@ -268,3 +288,3 @@ exports.matchQuery = matchQuery;
 exports.never = never;
-const optional = /*#__PURE__*/Debug.untracedMethod(() => self => matchCauseQuery(self, cause => (0, _Function.pipe)(Cause.stripSomeDefects(cause, defect => queryFailure.isQueryFailure(defect) ? Option.some(void 0) : Option.none()), Option.match(succeedNone, failCause)), succeedSome));
+const optional = /*#__PURE__*/Debug.untracedMethod(() => self => matchCauseQuery(self, cause => Option.match(succeedNone, failCause)(Cause.stripSomeDefects(cause, defect => queryFailure.isQueryFailure(defect) ? Option.some(void 0) : Option.none())), succeedSome));
 /** @internal */
@@ -287,3 +307,3 @@ exports.optional = optional;
 exports.provideContext = provideContext;
-const provideLayer = /*#__PURE__*/Debug.dualWithTrace(2, trace => (self, layer) => new QueryImpl(Effect.scoped((0, _Function.pipe)(Effect.exit(Layer.build(layer.value)), Effect.flatMap(Exit.match(e => Effect.succeed(Result.fail(e)), c => provideContext(self, described.make(c, layer.description)).step)))).traced(trace)));
+const provideLayer = /*#__PURE__*/Debug.dualWithTrace(2, trace => (self, layer) => new QueryImpl(Effect.scoped(Effect.flatMap(Exit.match(e => Effect.succeed(Result.fail(e)), c => provideContext(self, described.make(c, layer.description)).step))(Effect.exit(Layer.build(layer.value)))).traced(trace)));
 /** @internal */
@@ -330,6 +350,6 @@ exports.provideLayer = provideLayer;
 exports.refineOrDie = refineOrDie;
-const refineOrDieWith = /*#__PURE__*/Debug.untracedDual(3, restore => (self, pf, f) => catchAll(self, e => (0, _Function.pipe)(restore(pf)(e), Option.match(() => die(restore(f)(e)), fail))));
+const refineOrDieWith = /*#__PURE__*/Debug.untracedDual(3, restore => (self, pf, f) => catchAll(self, e => Option.match(() => die(restore(f)(e)), fail)(restore(pf)(e))));
 /** @internal */
 exports.refineOrDieWith = refineOrDieWith;
-const right = /*#__PURE__*/Debug.untracedMethod(() => self => matchQuery(self, e => fail(Either.right(e)), e => (0, _Function.pipe)(e, Either.match(a => fail(Either.left(a)), succeed))));
+const right = /*#__PURE__*/Debug.untracedMethod(() => self => matchQuery(self, e => fail(Either.right(e)), e => Either.match(a => fail(Either.left(a)), succeed)(e)));
 /** @internal */
@@ -459,7 +479,7 @@ exports.right = right;
   }), (rightExit, leftFiber) => Effect.zipRight(Fiber.interrupt(leftFiber), Effect.succeed(Result.fromExit(rightExit)))));
-  return flatMap(fromEffect((0, _Function.pipe)(Effect.sleep(duration), Effect.interruptible, Effect.as(def), Effect.fork)), fiber => race(map(self, restore(f)), fiber));
+  return flatMap(fromEffect(Effect.fork(Effect.as(def)(Effect.interruptible(Effect.sleep(duration))))), fiber => race(map(self, restore(f)), fiber));
 });
 /** @internal */
 exports.timeoutTo = timeoutTo;
-const uncached = /*#__PURE__*/Debug.untracedMethod(() => self => (0, _Function.pipe)(fromEffect(FiberRef.getAndSet(cachingEnabled, false)), flatMap(previous => ensuring(self, fromEffect(FiberRef.set(cachingEnabled, previous))))));
+const uncached = /*#__PURE__*/Debug.untracedMethod(() => self => flatMap(previous => ensuring(self, fromEffect(FiberRef.set(cachingEnabled, previous))))(fromEffect(FiberRef.getAndSet(cachingEnabled, false))));
 /** @internal */
@@ -479,3 +499,3 @@ exports.uncached = uncached;
 exports.unrefine = unrefine;
-const unrefineWith = /*#__PURE__*/Debug.untracedDual(3, restore => (self, pf, f) => catchAllCause(self, cause => (0, _Function.pipe)(Cause.find(cause, cause => Cause.isDieType(cause) ? restore(pf)(cause.defect) : Option.none()), Option.match(() => failCause(Cause.map(cause, restore(f))), fail))));
+const unrefineWith = /*#__PURE__*/Debug.untracedDual(3, restore => (self, pf, f) => catchAllCause(self, cause => Option.match(() => failCause(Cause.map(cause, restore(f))), fail)(Cause.find(cause, cause => Cause.isDieType(cause) ? restore(pf)(cause.defect) : Option.none()))));
 /** @internal */
@@ -634,4 +654,4 @@ exports.unrefineWith = unrefineWith;
     const blockedRequests = Chunk.flatten(sequential);
-    const leftovers = (0, _Function.pipe)(completedRequestMap.requests(completedRequests), HashSet.difference(Chunk.map(blockedRequests, blockedRequest => blockedRequest.request)));
-    return (0, _Function.pipe)(Effect.forEachDiscard(blockedRequests, blockedRequest => Ref.set(blockedRequest.result, completedRequestMap.get(completedRequests, blockedRequest.request))), Effect.zipRight(Effect.forEachDiscard(leftovers, request => Effect.flatMap(Ref.make(completedRequestMap.get(completedRequests, request)), ref => Cache.set(currentCache, request, ref)))));
+    const leftovers = HashSet.difference(Chunk.map(blockedRequests, blockedRequest => blockedRequest.request))(completedRequestMap.requests(completedRequests));
+    return Effect.zipRight(Effect.forEachDiscard(leftovers, request => Effect.flatMap(Ref.make(completedRequestMap.get(completedRequests, request)), ref => Cache.set(currentCache, request, ref))))(Effect.forEachDiscard(blockedRequests, blockedRequest => Ref.set(blockedRequest.result, completedRequestMap.get(completedRequests, blockedRequest.request))));
   }))));
@@ -646,3 +666,3 @@ };
   for (let i = 0; i < self.length; i++) {
-    const a = (0, _Function.pipe)(self, Chunk.unsafeGet(i));
+    const a = Chunk.unsafeGet(i)(self);
     const e = f(a);
@@ -691,7 +711,7 @@ if (Either.isLeft(e)) {
     for (let i = 0; i < chunk.length; i++) {
-      array[indices[i]] = (0, _Function.pipe)(chunk, Chunk.unsafeGet(i));
+      array[indices[i]] = Chunk.unsafeGet(i)(chunk);
     }
     return map(fromEffect(Effect.collectAll(effects.map(tuple => tuple[0]))), chunk => {
       for (let i = 0; i < chunk.length; i++) {
-        array[effects[i][1]] = (0, _Function.pipe)(chunk, Chunk.unsafeGet(i));
+        array[effects[i][1]] = Chunk.unsafeGet(i)(chunk);
       }
@@ -938,3 +958,3 @@ return Chunk.fromIterable(array);
       for (let i = 0; i < chunk.length; i++) {
-        array[indices[i]] = (0, _Function.pipe)(chunk, Chunk.unsafeGet(i));
+        array[indices[i]] = Chunk.unsafeGet(i)(chunk);
       }
@@ -941,0 +961,0 @@ for (let i = 0; i < done.length; i++) {

internal/sequential.js

@@ -7,3 +7,2 @@ "use strict";
 exports.toChunk = exports.make = exports.keys = exports.isEmpty = exports.combine = exports.SequentialTypeId = void 0;
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
@@ -45,3 +44,3 @@ var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
 exports.make = make;
-const combine = (self, that) => new SequentialImpl(HashMap.reduceWithIndex(that.map, self.map, (map, value, key) => HashMap.set(map, key, (0, _Function.pipe)(HashMap.get(map, key), Option.match(() => Chunk.empty(), Chunk.concat(value))))));
+const combine = (self, that) => new SequentialImpl(HashMap.reduceWithIndex(that.map, self.map, (map, value, key) => HashMap.set(map, key, Option.match(() => Chunk.empty(), Chunk.concat(value))(HashMap.get(map, key)))));
 /**
@@ -48,0 +47,0 @@ * Returns whether this collection of batches of requests is empty.

package.json

 {
   "name": "@effect/query",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "license": "MIT",
@@ -5,0 +5,0 @@ "repository": {

Query.d.ts

@@ -5,2 +5,3 @@ /**
 import type * as Cause from "@effect/io/Cause";
+import type * as Debug from "@effect/io/Debug";
 import type * as Effect from "@effect/io/Effect";
@@ -69,3 +70,4 @@ import type * as Layer from "@effect/io/Layer";
  */
-export interface Query<R, E, A> extends Query.Variance<R, E, A> {
+export interface Query<R, E, A> extends Query.Variance<R, E, A>, Effect.Effect<R, E, A> {
+    traced(trace: Debug.Trace): Query<R, E, A>;
 }
@@ -72,0 +74,0 @@ /**

src/Query.ts

@@ -5,2 +5,3 @@ /**
 import type * as Cause from "@effect/io/Cause"
+import type * as Debug from "@effect/io/Debug"
 import type * as Effect from "@effect/io/Effect"
@@ -74,3 +75,5 @@ import type * as Layer from "@effect/io/Layer"
  */
-export interface Query<R, E, A> extends Query.Variance<R, E, A> {
+export interface Query<R, E, A> extends Query.Variance<R, E, A>, Effect.Effect<R, E, A> {
+  traced(trace: Debug.Trace): Query<R, E, A>
+
   /** @internal */
@@ -77,0 +80,0 @@ readonly step: Effect.Effect<R, never, Result.Result<R, E, A>>

tsconfig.base.json

@@ -53,10 +53,3 @@ {
       }
-    ],
-    "transformers": [
-      {
-        "name": "@effect/language-service/transformer",
-        "trace": { "exclude": ["**/*.ts"] }
-      }
-    ],
-    "tsPlusEnabled": false
+    ]
   },
@@ -63,0 +56,0 @@ "include": [],

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

789416

increased by0.08%

Lines of code

14121

increased by0.38%

Number of medium supply chain risk alerts

0

decreased by-100%

No dependency changes