@effect/io - npm Package Compare versions

Comparing version 0.32.2 to 0.33.0

internal/blockedRequests.js

@@ -316,3 +316,3 @@ "use strict";
 exports.parallelCollectionMake = parallelCollectionMake;
-const parallelCollectionCombine = (self, that) => new ParallelImpl(HashMap.reduceWithIndex(self.map, that.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), {
+const parallelCollectionCombine = (self, that) => new ParallelImpl(HashMap.reduce(self.map, that.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), {
   onNone: () => value,
@@ -352,3 +352,3 @@ onSome: a => [...a, ...value]
 exports.sequentialCollectionMake = sequentialCollectionMake;
-const sequentialCollectionCombine = (self, that) => new SequentialImpl(HashMap.reduceWithIndex(that.map, self.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), {
+const sequentialCollectionCombine = (self, that) => new SequentialImpl(HashMap.reduce(that.map, self.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), {
   onNone: () => [],
@@ -355,0 +355,0 @@ onSome: a => [...a, ...value]

internal/concurrency.js

@@ -12,26 +12,20 @@ "use strict";
 const match = (options, sequential, unbounded, bounded) => {
-  let effect;
   switch (options?.concurrency) {
     case undefined:
       {
-        effect = sequential();
-        break;
+        return sequential();
       }
     case "unbounded":
       {
-        effect = unbounded();
-        break;
+        return unbounded();
       }
     case "inherit":
       {
-        effect = core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? unbounded() : concurrency > 1 ? bounded(concurrency) : sequential());
-        break;
+        return core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? unbounded() : concurrency > 1 ? bounded(concurrency) : sequential());
       }
     default:
       {
-        effect = options.concurrency > 1 ? bounded(options.concurrency) : sequential();
-        break;
+        return options.concurrency > 1 ? bounded(options.concurrency) : sequential();
       }
   }
-  return effect;
 };
@@ -41,28 +35,22 @@ /** @internal */
 const matchSimple = (options, sequential, concurrent) => {
-  let effect;
   switch (options?.concurrency) {
     case undefined:
       {
-        effect = sequential();
-        break;
+        return sequential();
       }
     case "unbounded":
       {
-        effect = concurrent();
-        break;
+        return concurrent();
       }
     case "inherit":
       {
-        effect = core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? concurrent() : concurrency > 1 ? concurrent() : sequential());
-        break;
+        return core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? concurrent() : concurrency > 1 ? concurrent() : sequential());
       }
     default:
       {
-        effect = options.concurrency > 1 ? concurrent() : sequential();
-        break;
+        return options.concurrency > 1 ? concurrent() : sequential();
       }
   }
-  return effect;
 };
 exports.matchSimple = matchSimple;
 //# sourceMappingURL=concurrency.js.map

internal/configProvider/pathPatch.js

@@ -12,3 +12,2 @@ "use strict";
 var RA = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));
-var String = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/String"));
 var configError = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/configError"));
@@ -78,3 +77,3 @@ 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); }
         {
-          const containsName = Option.contains(String.Equivalence)(patch.name)(RA.head(output));
+          const containsName = Option.contains(patch.name)(RA.head(output));
           if (containsName) {
@@ -81,0 +80,0 @@ output = RA.tailNonEmpty(output);

internal/effect.js

@@ -375,5 +375,4 @@ "use strict";
 const ignoreLogged = self => core.matchCauseEffect(self, {
-  onFailure: cause => logCause(cause, {
-    message: "An error was silently ignored because it is not anticipated to be useful",
-    level: "Debug"
+  onFailure: cause => logCause(cause, "Debug", {
+    message: "An error was silently ignored because it is not anticipated to be useful"
   }),
@@ -407,10 +406,10 @@ onSuccess: () => core.unit
 exports.iterate = iterate;
-const log = /*#__PURE__*/(0, _Function.dual)(args => typeof args[0] === "string", (message, options) => core.withFiberRuntime(fiberState => {
-  fiberState.log(message, options?.cause ?? internalCause.empty, options?.level ? Option.some(LogLevel.fromLiteral(options.level)) : Option.none());
+const log = (message, level, options) => core.withFiberRuntime(fiberState => {
+  fiberState.log(message, options?.cause ?? internalCause.empty, level ? Option.some(LogLevel.fromLiteral(level)) : Option.none());
   return core.unit;
-}));
+});
 /* @internal */
 exports.log = log;
-const logCause = /*#__PURE__*/(0, _Function.dual)(args => internalCause.isCause(args[0]), (cause, options) => core.withFiberRuntime(fiberState => {
-  fiberState.log(options?.message ?? "", cause, options?.level ? Option.some(LogLevel.fromLiteral(options.level)) : Option.none());
+const logCause = /*#__PURE__*/(0, _Function.dual)(args => internalCause.isCause(args[0]), (cause, level, options) => core.withFiberRuntime(fiberState => {
+  fiberState.log(options?.message ?? "", cause, level ? Option.some(LogLevel.fromLiteral(level)) : Option.none());
   return core.unit;
@@ -420,6 +419,6 @@ }));
 exports.logCause = logCause;
-const withLog = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, message, options) => core.zipLeft(self, log(message, options)));
+const withLog = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, message, level, options) => core.zipLeft(self, log(message, level, options)));
 /* @internal */
 exports.withLog = withLog;
-const withLogCause = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, options) => tapErrorCause(self, logCause(options)));
+const withLogCause = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, level, options) => tapErrorCause(self, logCause(level, options)));
 /* @internal */
@@ -773,3 +772,3 @@ exports.withLogCause = withLogCause;
     const span = tracer.span(name, parent, options?.context ?? Context.empty(), startTime);
-    HashMap.forEachWithIndex(annotations, (value, key) => span.attribute(key, value));
+    HashMap.forEach(annotations, (value, key) => span.attribute(key, value));
     Object.entries(options?.attributes ?? {}).forEach(([k, v]) => {
@@ -776,0 +775,0 @@ span.attribute(k, v);

internal/fiber.js

@@ -47,3 +47,3 @@ "use strict";
 exports.RuntimeFiberTypeId = RuntimeFiberTypeId;
-const Order = /*#__PURE__*/order.contramap(fiber => [fiber.id().startTimeMillis, fiber.id().id])( /*#__PURE__*/order.tuple(number.Order, number.Order));
+const Order = /*#__PURE__*/order.mapInput(fiber => [fiber.id().startTimeMillis, fiber.id().id])( /*#__PURE__*/order.tuple(number.Order, number.Order));
 /** @internal */
@@ -50,0 +50,0 @@ exports.Order = Order;

internal/random.js

@@ -9,3 +9,3 @@ "use strict";
 var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
-var PCGRandom = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Random"));
+var DeterministicRandom = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/DeterministicRandom"));
 var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));
@@ -28,3 +28,3 @@ 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); }
     this[_a] = RandomTypeId;
-    this.PRNG = new PCGRandom.PCGRandom(seed);
+    this.PRNG = new DeterministicRandom.PCGRandom(seed);
   }
@@ -31,0 +31,0 @@ next() {

internal/testing/testClock.js

@@ -166,5 +166,3 @@ "use strict";
   warningStart() {
-    return synchronized.updateSomeEffect(this.warningState, data => WarningData.isStart(data) ? Option.some(core.map(fiber => WarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(effect.log(warning, {
-      level: "Warning"
-    }))))))) : Option.none());
+    return synchronized.updateSomeEffect(this.warningState, data => WarningData.isStart(data) ? Option.some(core.map(fiber => WarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(effect.log(warning, "Warning"))))))) : Option.none());
   }
@@ -205,5 +203,3 @@ /**
       if (SuspendedWarningData.isStart(suspendedWarningData)) {
-        return Option.some(core.map(fiber => SuspendedWarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(core.zipRight(ref.set(this.suspendedWarningState, SuspendedWarningData.done))(effect.log(suspendedWarning, {
-          level: "Warning"
-        }))))))));
+        return Option.some(core.map(fiber => SuspendedWarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(core.zipRight(ref.set(this.suspendedWarningState, SuspendedWarningData.done))(effect.log(suspendedWarning, "Warning"))))))));
       }
@@ -244,3 +240,3 @@ return Option.none();
       const end = f(data.instant);
-      const sorted = Chunk.sort(Order.contramap(_ => _[0])(number.Order))(data.sleeps);
+      const sorted = Chunk.sort(Order.mapInput(_ => _[0])(number.Order))(data.sleeps);
       if (Chunk.isNonEmpty(sorted)) {
@@ -247,0 +243,0 @@ const [instant, deferred] = Chunk.headNonEmpty(sorted);

Layer.d.ts

@@ -557,4 +557,4 @@ /**
 export declare const tap: {
-    <ROut, RIn2, E2, X>(f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>): <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>;
-    <RIn, E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>;
+    <ROut, XR extends ROut, RIn2, E2, X>(f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>): <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>;
+    <RIn, E, ROut, XR extends ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>;
 };
@@ -568,4 +568,4 @@ /**
 export declare const tapError: {
-    <E, RIn2, E2, X>(f: (e: E) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>;
-    <RIn, E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (e: E) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>;
+    <E, XE extends E, RIn2, E2, X>(f: (e: XE) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>;
+    <RIn, E, XE extends E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (e: XE) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>;
 };
@@ -579,4 +579,4 @@ /**
 export declare const tapErrorCause: {
-    <E, RIn2, E2, X>(f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>;
-    <RIn, E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>;
+    <E, XE extends E, RIn2, E2, X>(f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>;
+    <RIn, E, XE extends E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>;
 };
@@ -583,0 +583,0 @@ /**

Logger/Level.js

@@ -84,3 +84,3 @@ "use strict";
 exports.locally = locally;
-const Order = /*#__PURE__*/order.contramap(level => level.ordinal)(number.Order);
+const Order = /*#__PURE__*/order.mapInput(level => level.ordinal)(number.Order);
 /**
@@ -87,0 +87,0 @@ * @since 1.0.0

package.json

 {
   "name": "@effect/io",
-  "version": "0.32.2",
+  "version": "0.33.0",
   "license": "MIT",
@@ -10,3 +10,3 @@ "repository": {
   "dependencies": {
-    "@effect/data": "^0.14.1"
+    "@effect/data": "^0.15.0"
   },
@@ -13,0 +13,0 @@ "publishConfig": {

Schedule.d.ts

@@ -891,4 +891,4 @@ /**
 export declare const tapOutput: {
-    <Out, Env2, X>(f: (out: Out) => Effect.Effect<Env2, never, X>): <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
-    <Env, In, Out, Env2, X>(self: Schedule<Env, In, Out>, f: (out: Out) => Effect.Effect<Env2, never, X>): Schedule<Env | Env2, In, Out>;
+    <Out, XO extends Out, Env2, X>(f: (out: XO) => Effect.Effect<Env2, never, X>): <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
+    <Env, In, Out, XO extends Out, Env2, X>(self: Schedule<Env, In, Out>, f: (out: XO) => Effect.Effect<Env2, never, X>): Schedule<Env | Env2, In, Out>;
 };
@@ -895,0 +895,0 @@ /**

src/internal/blockedRequests.ts

@@ -380,3 +380,3 @@ import * as Either from "@effect/data/Either"
 ): ParallelCollection<R | R2> =>
-  new ParallelImpl(HashMap.reduceWithIndex(self.map, that.map, (map, value, key) =>
+  new ParallelImpl(HashMap.reduce(self.map, that.map, (map, value, key) =>
     HashMap.set(
@@ -447,3 +447,3 @@ map,
 ): SequentialCollection<R | R2> =>
-  new SequentialImpl(HashMap.reduceWithIndex(that.map, self.map, (map, value, key) =>
+  new SequentialImpl(HashMap.reduce(that.map, self.map, (map, value, key) =>
     HashMap.set(
@@ -450,0 +450,0 @@ map,

src/internal/concurrency.ts

@@ -21,14 +21,11 @@ import type { Concurrency } from "@effect/io/Concurrency"
 ) => {
-  let effect: Effect<R, E, A>
   switch (options?.concurrency) {
     case undefined: {
-      effect = sequential()
-      break
+      return sequential()
     }
     case "unbounded": {
-      effect = unbounded()
-      break
+      return unbounded()
     }
     case "inherit": {
-      effect = core.fiberRefGetWith(
+      return core.fiberRefGetWith(
         core.currentConcurrency,
@@ -42,12 +39,9 @@ (concurrency) =>
       )
-      break
     }
     default: {
-      effect = options!.concurrency > 1 ?
+      return options!.concurrency > 1 ?
         bounded(options!.concurrency) :
         sequential()
-      break
     }
   }
-  return effect
 }
@@ -69,14 +63,11 @@
 ) => {
-  let effect: Effect<R, E, A>
   switch (options?.concurrency) {
     case undefined: {
-      effect = sequential()
-      break
+      return sequential()
     }
     case "unbounded": {
-      effect = concurrent()
-      break
+      return concurrent()
     }
     case "inherit": {
-      effect = core.fiberRefGetWith(
+      return core.fiberRefGetWith(
         core.currentConcurrency,
@@ -90,11 +81,7 @@ (concurrency) =>
       )
-      break
     }
     default: {
-      effect = options!.concurrency > 1 ? concurrent() : sequential()
-      break
+      return options!.concurrency > 1 ? concurrent() : sequential()
     }
   }
-
-  return effect
 }

src/internal/configProvider/pathPatch.ts

@@ -6,3 +6,2 @@ import * as Either from "@effect/data/Either"
 import * as RA from "@effect/data/ReadonlyArray"
-import * as String from "@effect/data/String"
 import type * as ConfigError from "@effect/io/Config/Error"
@@ -83,3 +82,3 @@ import type * as PathPatch from "@effect/io/Config/Provider/PathPatch"
           RA.head(output),
-          Option.contains(String.Equivalence)(patch.name)
+          Option.contains(patch.name)
         )
@@ -86,0 +85,0 @@ if (containsName) {

src/internal/fiber.ts

@@ -52,3 +52,3 @@ import * as Either from "@effect/data/Either"
   order.tuple<readonly [order.Order<number>, order.Order<number>]>(number.Order, number.Order),
-  order.contramap((fiber: Fiber.RuntimeFiber<unknown, unknown>) =>
+  order.mapInput((fiber: Fiber.RuntimeFiber<unknown, unknown>) =>
     [
@@ -55,0 +55,0 @@ (fiber.id() as FiberId.Runtime).startTimeMillis,

src/internal/layer.ts

@@ -982,8 +982,8 @@ import * as Context from "@effect/data/Context"
 export const tap = dual<
-  <ROut, RIn2, E2, X>(
-    f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>
+  <ROut, XR extends ROut, RIn2, E2, X>(
+    f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>
   ) => <RIn, E>(self: Layer.Layer<RIn, E, ROut>) => Layer.Layer<RIn | RIn2, E | E2, ROut>,
-  <RIn, E, ROut, RIn2, E2, X>(
+  <RIn, E, ROut, XR extends ROut, RIn2, E2, X>(
     self: Layer.Layer<RIn, E, ROut>,
-    f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>
+    f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>
   ) => Layer.Layer<RIn | RIn2, E | E2, ROut>
@@ -994,8 +994,8 @@ >(2, (self, f) => flatMap(self, (context) => fromEffectContext(core.as(f(context), context))))
 export const tapError = dual<
-  <E, RIn2, E2, X>(
-    f: (e: E) => Effect.Effect<RIn2, E2, X>
+  <E, XE extends E, RIn2, E2, X>(
+    f: (e: XE) => Effect.Effect<RIn2, E2, X>
   ) => <RIn, ROut>(self: Layer.Layer<RIn, E, ROut>) => Layer.Layer<RIn | RIn2, E | E2, ROut>,
-  <RIn, E, ROut, RIn2, E2, X>(
+  <RIn, E, XE extends E, ROut, RIn2, E2, X>(
     self: Layer.Layer<RIn, E, ROut>,
-    f: (e: E) => Effect.Effect<RIn2, E2, X>
+    f: (e: XE) => Effect.Effect<RIn2, E2, X>
   ) => Layer.Layer<RIn | RIn2, E | E2, ROut>
@@ -1005,3 +1005,3 @@ >(2, (self, f) =>
     self,
-    (e) => fromEffectContext(core.flatMap(f(e), () => core.fail(e)))
+    (e) => fromEffectContext(core.flatMap(f(e as any), () => core.fail(e)))
   ))
@@ -1011,8 +1011,8 @@
 export const tapErrorCause = dual<
-  <E, RIn2, E2, X>(
-    f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>
+  <E, XE extends E, RIn2, E2, X>(
+    f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>
   ) => <RIn, ROut>(self: Layer.Layer<RIn, E, ROut>) => Layer.Layer<RIn | RIn2, E | E2, ROut>,
-  <RIn, E, ROut, RIn2, E2, X>(
+  <RIn, E, XE extends E, ROut, RIn2, E2, X>(
     self: Layer.Layer<RIn, E, ROut>,
-    f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>
+    f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>
   ) => Layer.Layer<RIn | RIn2, E | E2, ROut>
@@ -1022,3 +1022,3 @@ >(2, (self, f) =>
     self,
-    (cause) => fromEffectContext(core.flatMap(f(cause), () => core.failCause(cause)))
+    (cause) => fromEffectContext(core.flatMap(f(cause as any), () => core.failCause(cause)))
   ))
@@ -1025,0 +1025,0 @@

src/internal/random.ts

 import * as Chunk from "@effect/data/Chunk"
 import * as Context from "@effect/data/Context"
+import * as DeterministicRandom from "@effect/data/DeterministicRandom"
 import { pipe } from "@effect/data/Function"
-import * as PCGRandom from "@effect/data/Random"
 import type * as Effect from "@effect/io/Effect"
@@ -23,6 +23,6 @@ import * as core from "@effect/io/internal/core"
 
-  readonly PRNG: PCGRandom.PCGRandom
+  readonly PRNG: DeterministicRandom.PCGRandom
 
   constructor(readonly seed: number) {
-    this.PRNG = new PCGRandom.PCGRandom(seed)
+    this.PRNG = new DeterministicRandom.PCGRandom(seed)
   }
@@ -29,0 +29,0 @@

src/internal/testing/testClock.ts

@@ -261,3 +261,3 @@ import * as Chunk from "@effect/data/Chunk"
             this.live.provide(
-              pipe(effect.log(warning, { level: "Warning" }), effect.delay(Duration.seconds(5)))
+              pipe(effect.log(warning, "Warning"), effect.delay(Duration.seconds(5)))
             ),
@@ -331,3 +331,3 @@ core.interruptible,
               pipe(
-                effect.log(suspendedWarning, { level: "Warning" }),
+                effect.log(suspendedWarning, "Warning"),
                 core.zipRight(ref.set(this.suspendedWarningState, SuspendedWarningData.done)),
@@ -370,3 +370,3 @@ effect.delay(Duration.seconds(5))
             data.sleeps,
-            Chunk.sort<readonly [number, Deferred<never, void>]>(pipe(number.Order, Order.contramap((_) => _[0])))
+            Chunk.sort<readonly [number, Deferred<never, void>]>(pipe(number.Order, Order.mapInput((_) => _[0])))
           )
@@ -373,0 +373,0 @@ if (Chunk.isNonEmpty(sorted)) {

src/Layer.ts

@@ -716,8 +716,8 @@ /**
 export const tap: {
-  <ROut, RIn2, E2, X>(
-    f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>
+  <ROut, XR extends ROut, RIn2, E2, X>(
+    f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>
   ): <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>
-  <RIn, E, ROut, RIn2, E2, X>(
+  <RIn, E, ROut, XR extends ROut, RIn2, E2, X>(
     self: Layer<RIn, E, ROut>,
-    f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>
+    f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>
   ): Layer<RIn | RIn2, E | E2, ROut>
@@ -733,8 +733,8 @@ } = internal.tap
 export const tapError: {
-  <E, RIn2, E2, X>(
-    f: (e: E) => Effect.Effect<RIn2, E2, X>
+  <E, XE extends E, RIn2, E2, X>(
+    f: (e: XE) => Effect.Effect<RIn2, E2, X>
   ): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>
-  <RIn, E, ROut, RIn2, E2, X>(
+  <RIn, E, XE extends E, ROut, RIn2, E2, X>(
     self: Layer<RIn, E, ROut>,
-    f: (e: E) => Effect.Effect<RIn2, E2, X>
+    f: (e: XE) => Effect.Effect<RIn2, E2, X>
   ): Layer<RIn | RIn2, E | E2, ROut>
@@ -750,8 +750,8 @@ } = internal.tapError
 export const tapErrorCause: {
-  <E, RIn2, E2, X>(
-    f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>
+  <E, XE extends E, RIn2, E2, X>(
+    f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>
   ): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>
-  <RIn, E, ROut, RIn2, E2, X>(
+  <RIn, E, XE extends E, ROut, RIn2, E2, X>(
     self: Layer<RIn, E, ROut>,
-    f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>
+    f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>
   ): Layer<RIn | RIn2, E | E2, ROut>
@@ -758,0 +758,0 @@ } = internal.tapErrorCause

src/Logger/Level.ts

@@ -194,3 +194,3 @@ /**
   number.Order,
-  order.contramap((level: LogLevel) => level.ordinal)
+  order.mapInput((level: LogLevel) => level.ordinal)
 )
@@ -197,0 +197,0 @@

src/Schedule.ts

@@ -1145,8 +1145,8 @@ /**
 export const tapOutput: {
-  <Out, Env2, X>(
-    f: (out: Out) => Effect.Effect<Env2, never, X>
+  <Out, XO extends Out, Env2, X>(
+    f: (out: XO) => Effect.Effect<Env2, never, X>
   ): <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>
-  <Env, In, Out, Env2, X>(
+  <Env, In, Out, XO extends Out, Env2, X>(
     self: Schedule<Env, In, Out>,
-    f: (out: Out) => Effect.Effect<Env2, never, X>
+    f: (out: XO) => Effect.Effect<Env2, never, X>
   ): Schedule<Env | Env2, In, Out>
@@ -1153,0 +1153,0 @@ } = internal.tapOutput

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

Worsened metrics

Total package byte prevSize

6373472

decreased by-0.01%

Lines of code

113743

decreased by-0.07%

Dependency changes

• + Added@effect/data@0.15.1(transitive)

• - Removed@effect/data@0.14.3(transitive)

• Updated@effect/data@^0.15.0