@effect/stm - npm Package Compare versions

Comparing version 0.17.0 to 0.18.0

internal/core.js

@@ -6,3 +6,3 @@ "use strict";
 });
-exports.zipWith = exports.zipRight = exports.zipLeft = exports.zip = exports.withSTMRuntime = exports.unsafeAtomically = exports.sync = exports.succeed = exports.retry = exports.orTry = exports.matchSTM = exports.map = exports.isSTM = exports.interruptAs = exports.interrupt = exports.flatMap = exports.failSync = exports.fail = exports.ensuring = exports.effect = exports.dieSync = exports.dieMessage = exports.die = exports.contramapContext = exports.contextWithSTM = exports.contextWith = exports.context = exports.commit = exports.catchAll = exports.STMTypeId = exports.STMDriver = void 0;
+exports.zipWith = exports.zipRight = exports.zipLeft = exports.zip = exports.withSTMRuntime = exports.unsafeAtomically = exports.sync = exports.succeed = exports.retry = exports.orTry = exports.matchSTM = exports.mapInputContext = exports.map = exports.isSTM = exports.interruptAs = exports.interrupt = exports.flatMap = exports.failSync = exports.fail = exports.ensuring = exports.effect = exports.dieSync = exports.dieMessage = exports.die = exports.contextWithSTM = exports.contextWith = exports.context = exports.commit = exports.catchAll = exports.STMTypeId = exports.STMDriver = void 0;
 var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
@@ -394,3 +394,3 @@ var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Either"));
 exports.catchAll = catchAll;
-const contramapContext = /*#__PURE__*/(0, _Function.dual)(2, (self, f) => {
+const mapInputContext = /*#__PURE__*/(0, _Function.dual)(2, (self, f) => {
   const stm = new STMPrimitive(OpCodes.OP_PROVIDE);
@@ -402,3 +402,3 @@ stm.i1 = self;
 /** @internal */
-exports.contramapContext = contramapContext;
+exports.mapInputContext = mapInputContext;
 const die = defect => dieSync(() => defect);
@@ -405,0 +405,0 @@ /** @internal */

internal/stm.js

@@ -421,6 +421,6 @@ "use strict";
 exports.orElseSucceed = orElseSucceed;
-const provideContext = /*#__PURE__*/(0, _Function.dual)(2, (self, env) => core.contramapContext(self, _ => env));
+const provideContext = /*#__PURE__*/(0, _Function.dual)(2, (self, env) => core.mapInputContext(self, _ => env));
 /** @internal */
 exports.provideContext = provideContext;
-const provideSomeContext = /*#__PURE__*/(0, _Function.dual)(2, (self, context) => core.contramapContext(self, parent => Context.merge(parent, context)));
+const provideSomeContext = /*#__PURE__*/(0, _Function.dual)(2, (self, context) => core.mapInputContext(self, parent => Context.merge(parent, context)));
 /** @internal */
@@ -427,0 +427,0 @@ exports.provideSomeContext = provideSomeContext;

package.json

 {
   "name": "@effect/stm",
-  "version": "0.17.0",
+  "version": "0.18.0",
   "license": "MIT",
@@ -10,4 +10,4 @@ "repository": {
   "dependencies": {
-    "@effect/data": "^0.15.0",
-    "@effect/io": "^0.33.0"
+    "@effect/data": "^0.15.1",
+    "@effect/io": "^0.34.0"
   },
@@ -14,0 +14,0 @@ "publishConfig": {

src/internal/core.ts

@@ -582,3 +582,3 @@ import * as Context from "@effect/data/Context"
 /** @internal */
-export const contramapContext = dual<
+export const mapInputContext = dual<
   <R0, R>(
@@ -585,0 +585,0 @@ f: (context: Context.Context<R0>) => Context.Context<R>

src/internal/stm.ts

@@ -427,7 +427,23 @@ import * as Chunk from "@effect/data/Chunk"
 export const filterOrDie = dual<
-  <A>(predicate: Predicate<A>, defect: LazyArg<unknown>) => <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E, A>,
-  <R, E, A>(self: STM.STM<R, E, A>, predicate: Predicate<A>, defect: LazyArg<unknown>) => STM.STM<R, E, A>
+  {
+    <A, B extends A>(
+      refinement: Refinement<A, B>,
+      defect: LazyArg<unknown>
+    ): <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E, B>
+    <A, X extends A>(
+      predicate: Predicate<X>,
+      defect: LazyArg<unknown>
+    ): <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E, A>
+  },
+  {
+    <R, E, A, B extends A>(
+      self: STM.STM<R, E, A>,
+      refinement: Refinement<A, B>,
+      defect: LazyArg<unknown>
+    ): STM.STM<R, E, B>
+    <R, E, A, X extends A>(self: STM.STM<R, E, A>, predicate: Predicate<X>, defect: LazyArg<unknown>): STM.STM<R, E, A>
+  }
 >(
   3,
-  <R, E, A>(self: STM.STM<R, E, A>, predicate: Predicate<A>, defect: LazyArg<unknown>): STM.STM<R, E, A> =>
+  <R, E, A, X extends A>(self: STM.STM<R, E, A>, predicate: Predicate<X>, defect: LazyArg<unknown>): STM.STM<R, E, A> =>
     filterOrElse(self, predicate, () => core.dieSync(defect))
@@ -438,4 +454,10 @@ )
 export const filterOrDieMessage = dual<
-  <A>(predicate: Predicate<A>, message: string) => <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E, A>,
-  <R, E, A>(self: STM.STM<R, E, A>, predicate: Predicate<A>, message: string) => STM.STM<R, E, A>
+  {
+    <A, B extends A>(refinement: Refinement<A, B>, message: string): <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E, B>
+    <A, X extends A>(predicate: Predicate<X>, message: string): <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E, A>
+  },
+  {
+    <R, E, A, B extends A>(self: STM.STM<R, E, A>, refinement: Refinement<A, B>, message: string): STM.STM<R, E, B>
+    <R, E, A, X extends A>(self: STM.STM<R, E, A>, predicate: Predicate<X>, message: string): STM.STM<R, E, A>
+  }
 >(
@@ -448,24 +470,39 @@ 3,
 export const filterOrElse = dual<
-  <A, R2, E2, A2>(
-    predicate: Predicate<A>,
-    orElse: (a: A) => STM.STM<R2, E2, A2>
-  ) => <R, E>(
-    self: STM.STM<R, E, A>
-  ) => STM.STM<R2 | R, E2 | E, A | A2>,
-  <R, E, A, R2, E2, A2>(
-    self: STM.STM<R, E, A>,
-    predicate: Predicate<A>,
-    orElse: (a: A) => STM.STM<R2, E2, A2>
-  ) => STM.STM<R2 | R, E2 | E, A | A2>
+  {
+    <A, B extends A, X extends A, R2, E2, A2>(
+      refinement: Refinement<A, B>,
+      orElse: (a: X) => STM.STM<R2, E2, A2>
+    ): <R, E>(
+      self: STM.STM<R, E, A>
+    ) => STM.STM<R2 | R, E2 | E, B | A2>
+    <A, X extends A, Y extends A, R2, E2, A2>(
+      predicate: Predicate<X>,
+      orElse: (a: Y) => STM.STM<R2, E2, A2>
+    ): <R, E>(
+      self: STM.STM<R, E, A>
+    ) => STM.STM<R2 | R, E2 | E, A | A2>
+  },
+  {
+    <R, E, A, B extends A, X extends A, R2, E2, A2>(
+      self: STM.STM<R, E, A>,
+      refinement: Refinement<A, B>,
+      orElse: (a: X) => STM.STM<R2, E2, A2>
+    ): STM.STM<R2 | R, E2 | E, B | A2>
+    <R, E, A, X extends A, Y extends A, R2, E2, A2>(
+      self: STM.STM<R, E, A>,
+      predicate: Predicate<X>,
+      orElse: (a: Y) => STM.STM<R2, E2, A2>
+    ): STM.STM<R2 | R, E2 | E, A | A2>
+  }
 >(
   3,
-  <R, E, A, R2, E2, A2>(
+  <R, E, A, X extends A, Y extends A, R2, E2, A2>(
     self: STM.STM<R, E, A>,
-    predicate: Predicate<A>,
-    orElse: (a: A) => STM.STM<R2, E2, A2>
+    predicate: Predicate<X>,
+    orElse: (a: Y) => STM.STM<R2, E2, A2>
   ): STM.STM<R2 | R, E2 | E, A | A2> =>
     core.flatMap(self, (a): STM.STM<R | R2, E | E2, A | A2> =>
-      predicate(a) ?
+      predicate(a as X) ?
         core.succeed(a) :
-        orElse(a))
+        orElse(a as Y))
 )
@@ -475,4 +512,24 @@
 export const filterOrFail = dual<
-  <A, E2>(predicate: Predicate<A>, orFailWith: (a: A) => E2) => <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E2 | E, A>,
-  <R, E, A, E2>(self: STM.STM<R, E, A>, predicate: Predicate<A>, orFailWith: (a: A) => E2) => STM.STM<R, E2 | E, A>
+  {
+    <A, B extends A, X extends A, E2>(
+      refinement: Refinement<A, B>,
+      orFailWith: (a: X) => E2
+    ): <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E2 | E, B>
+    <A, X extends A, Y extends A, E2>(
+      predicate: Predicate<X>,
+      orFailWith: (a: Y) => E2
+    ): <R, E>(self: STM.STM<R, E, A>) => STM.STM<R, E2 | E, A>
+  },
+  {
+    <R, E, A, B extends A, X extends A, E2>(
+      self: STM.STM<R, E, A>,
+      refinement: Refinement<A, B>,
+      orFailWith: (a: X) => E2
+    ): STM.STM<R, E2 | E, B>
+    <R, E, A, X extends A, Y extends A, E2>(
+      self: STM.STM<R, E, A>,
+      predicate: Predicate<X>,
+      orFailWith: (a: Y) => E2
+    ): STM.STM<R, E2 | E, A>
+  }
 >(3, (self, predicate, orFailWith) =>
@@ -482,3 +539,3 @@ filterOrElse(
     predicate,
-    (a) => core.failSync(() => orFailWith(a))
+    (a) => core.failSync(() => orFailWith(a as any))
   ))
@@ -954,3 +1011,3 @@
   <E, A, R>(self: STM.STM<R, E, A>, env: Context.Context<R>) => STM.STM<never, E, A>
->(2, (self, env) => core.contramapContext(self, (_: Context.Context<never>) => env))
+>(2, (self, env) => core.mapInputContext(self, (_: Context.Context<never>) => env))
 
@@ -965,3 +1022,3 @@ /** @internal */
 ): STM.STM<Exclude<R1, R>, E, A> =>
-  core.contramapContext(
+  core.mapInputContext(
     self,
@@ -1282,12 +1339,17 @@ (parent: Context.Context<Exclude<R1, R>>): Context.Context<R1> => Context.merge(parent, context) as any
 export const tap = dual<
-  <A, R2, E2, _>(f: (a: A) => STM.STM<R2, E2, _>) => <R, E>(self: STM.STM<R, E, A>) => STM.STM<R2 | R, E2 | E, A>,
-  <R, E, A, R2, E2, _>(self: STM.STM<R, E, A>, f: (a: A) => STM.STM<R2, E2, _>) => STM.STM<R2 | R, E2 | E, A>
->(2, (self, f) => core.flatMap(self, (a) => as(f(a), a)))
+  <A, X extends A, R2, E2, _>(
+    f: (a: X) => STM.STM<R2, E2, _>
+  ) => <R, E>(self: STM.STM<R, E, A>) => STM.STM<R2 | R, E2 | E, A>,
+  <R, E, A, X extends A, R2, E2, _>(
+    self: STM.STM<R, E, A>,
+    f: (a: X) => STM.STM<R2, E2, _>
+  ) => STM.STM<R2 | R, E2 | E, A>
+>(2, (self, f) => core.flatMap(self, (a) => as(f(a as any), a)))
 
 /** @internal */
 export const tapBoth = dual<
-  <E, R2, E2, A2, A, R3, E3, A3>(
+  <E, XE extends E, R2, E2, A2, A, XA extends A, R3, E3, A3>(
     options: {
-      readonly onFailure: (error: E) => STM.STM<R2, E2, A2>
-      readonly onSuccess: (value: A) => STM.STM<R3, E3, A3>
+      readonly onFailure: (error: XE) => STM.STM<R2, E2, A2>
+      readonly onSuccess: (value: XA) => STM.STM<R3, E3, A3>
     }
@@ -1297,7 +1359,7 @@ ) => <R>(
   ) => STM.STM<R2 | R3 | R, E | E2 | E3, A>,
-  <R, E, R2, E2, A2, A, R3, E3, A3>(
+  <R, E, XE extends E, R2, E2, A2, A, XA extends A, R3, E3, A3>(
     self: STM.STM<R, E, A>,
     options: {
-      readonly onFailure: (error: E) => STM.STM<R2, E2, A2>
-      readonly onSuccess: (value: A) => STM.STM<R3, E3, A3>
+      readonly onFailure: (error: XE) => STM.STM<R2, E2, A2>
+      readonly onSuccess: (value: XA) => STM.STM<R3, E3, A3>
     }
@@ -1307,4 +1369,4 @@ ) => STM.STM<R2 | R3 | R, E | E2 | E3, A>
   core.matchSTM(self, {
-    onFailure: (e) => pipe(onFailure(e), core.zipRight(core.fail(e))),
-    onSuccess: (a) => pipe(onSuccess(a), as(a))
+    onFailure: (e) => pipe(onFailure(e as any), core.zipRight(core.fail(e))),
+    onSuccess: (a) => pipe(onSuccess(a as any), as(a))
   }))
@@ -1314,7 +1376,12 @@
 export const tapError = dual<
-  <E, R2, E2, _>(f: (error: E) => STM.STM<R2, E2, _>) => <R, A>(self: STM.STM<R, E, A>) => STM.STM<R2 | R, E | E2, A>,
-  <R, A, E, R2, E2, _>(self: STM.STM<R, E, A>, f: (error: E) => STM.STM<R2, E2, _>) => STM.STM<R2 | R, E | E2, A>
+  <E, X extends E, R2, E2, _>(
+    f: (error: X) => STM.STM<R2, E2, _>
+  ) => <R, A>(self: STM.STM<R, E, A>) => STM.STM<R2 | R, E | E2, A>,
+  <R, A, E, X extends E, R2, E2, _>(
+    self: STM.STM<R, E, A>,
+    f: (error: X) => STM.STM<R2, E2, _>
+  ) => STM.STM<R2 | R, E | E2, A>
 >(2, (self, f) =>
   core.matchSTM(self, {
-    onFailure: (e) => core.zipRight(f(e), core.fail(e)),
+    onFailure: (e) => core.zipRight(f(e as any), core.fail(e)),
     onSuccess: core.succeed
@@ -1325,3 +1392,2 @@ }))
 export const try_: {
-  <A>(try_: LazyArg<A>): STM.STM<never, unknown, A>
   <A, E>(options: {
@@ -1331,2 +1397,3 @@ readonly try: LazyArg<A>
   }): STM.STM<never, E, A>
+  <A>(try_: LazyArg<A>): STM.STM<never, unknown, A>
 } = <A, E>(
@@ -1333,0 +1400,0 @@ arg: LazyArg<A> | {

src/STM.ts

@@ -11,3 +11,3 @@ /**
 import type { Pipeable } from "@effect/data/Pipeable"
-import type { Predicate } from "@effect/data/Predicate"
+import type { Predicate, Refinement } from "@effect/data/Predicate"
 import type * as Unify from "@effect/data/Unify"
@@ -481,6 +481,6 @@ import * as Cause from "@effect/io/Cause"
  */
-export const contramapContext: {
+export const mapInputContext: {
   <R0, R>(f: (context: Context.Context<R0>) => Context.Context<R>): <E, A>(self: STM<R, E, A>) => STM<R0, E, A>
   <E, A, R0, R>(self: STM<R, E, A>, f: (context: Context.Context<R0>) => Context.Context<R>): STM<R0, E, A>
-} = core.contramapContext
+} = core.mapInputContext
 
@@ -620,4 +620,6 @@ /**
 export const filterOrDie: {
-  <A>(predicate: Predicate<A>, defect: LazyArg<unknown>): <R, E>(self: STM<R, E, A>) => STM<R, E, A>
-  <R, E, A>(self: STM<R, E, A>, predicate: Predicate<A>, defect: LazyArg<unknown>): STM<R, E, A>
+  <A, B extends A>(refinement: Refinement<A, B>, defect: LazyArg<unknown>): <R, E>(self: STM<R, E, A>) => STM<R, E, B>
+  <A, X extends A>(predicate: Predicate<X>, defect: LazyArg<unknown>): <R, E>(self: STM<R, E, A>) => STM<R, E, A>
+  <R, E, A, B extends A>(self: STM<R, E, A>, refinement: Refinement<A, B>, defect: LazyArg<unknown>): STM<R, E, B>
+  <R, E, A, X extends A>(self: STM<R, E, A>, predicate: Predicate<X>, defect: LazyArg<unknown>): STM<R, E, A>
 } = stm.filterOrDie
@@ -633,4 +635,6 @@
 export const filterOrDieMessage: {
-  <A>(predicate: Predicate<A>, message: string): <R, E>(self: STM<R, E, A>) => STM<R, E, A>
-  <R, E, A>(self: STM<R, E, A>, predicate: Predicate<A>, message: string): STM<R, E, A>
+  <A, B extends A>(refinement: Refinement<A, B>, message: string): <R, E>(self: STM<R, E, A>) => STM<R, E, B>
+  <A, X extends A>(predicate: Predicate<X>, message: string): <R, E>(self: STM<R, E, A>) => STM<R, E, A>
+  <R, E, A, B extends A>(self: STM<R, E, A>, refinement: Refinement<A, B>, message: string): STM<R, E, B>
+  <R, E, A, X extends A>(self: STM<R, E, A>, predicate: Predicate<X>, message: string): STM<R, E, A>
 } = stm.filterOrDieMessage
@@ -645,10 +649,19 @@
 export const filterOrElse: {
-  <A, R2, E2, A2>(
-    predicate: Predicate<A>,
-    orElse: (a: A) => STM<R2, E2, A2>
+  <A, B extends A, X extends A, R2, E2, A2>(
+    refinement: Refinement<A, B>,
+    orElse: (a: X) => STM<R2, E2, A2>
+  ): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, B | A2>
+  <A, X extends A, Y extends A, R2, E2, A2>(
+    predicate: Predicate<X>,
+    orElse: (a: Y) => STM<R2, E2, A2>
   ): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A | A2>
-  <R, E, A, R2, E2, A2>(
+  <R, E, A, B extends A, X extends A, R2, E2, A2>(
     self: STM<R, E, A>,
-    predicate: Predicate<A>,
-    orElse: (a: A) => STM<R2, E2, A2>
+    refinement: Refinement<A, B>,
+    orElse: (a: X) => STM<R2, E2, A2>
+  ): STM<R | R2, E | E2, B | A2>
+  <R, E, A, X extends A, Y extends A, R2, E2, A2>(
+    self: STM<R, E, A>,
+    predicate: Predicate<X>,
+    orElse: (a: Y) => STM<R2, E2, A2>
   ): STM<R | R2, E | E2, A | A2>
@@ -664,4 +677,20 @@ } = stm.filterOrElse
 export const filterOrFail: {
-  <A, E2>(predicate: Predicate<A>, orFailWith: (a: A) => E2): <R, E>(self: STM<R, E, A>) => STM<R, E2 | E, A>
-  <R, E, A, E2>(self: STM<R, E, A>, predicate: Predicate<A>, orFailWith: (a: A) => E2): STM<R, E | E2, A>
+  <A, B extends A, X extends A, E2>(
+    refinement: Refinement<A, B>,
+    orFailWith: (a: X) => E2
+  ): <R, E>(self: STM<R, E, A>) => STM<R, E2 | E, B>
+  <A, X extends A, Y extends A, E2>(
+    predicate: Predicate<X>,
+    orFailWith: (a: Y) => E2
+  ): <R, E>(self: STM<R, E, A>) => STM<R, E2 | E, A>
+  <R, E, A, B extends A, X extends A, E2>(
+    self: STM<R, E, A>,
+    refinement: Refinement<A, B>,
+    orFailWith: (a: X) => E2
+  ): STM<R, E | E2, B>
+  <R, E, A, X extends A, Y extends A, E2>(
+    self: STM<R, E, A>,
+    predicate: Predicate<X>,
+    orFailWith: (a: Y) => E2
+  ): STM<R, E | E2, A>
 } = stm.filterOrFail
@@ -1779,4 +1808,4 @@
 export const tap: {
-  <A, R2, E2, _>(f: (a: A) => STM<R2, E2, _>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A>
-  <R, E, A, R2, E2, _>(self: STM<R, E, A>, f: (a: A) => STM<R2, E2, _>): STM<R | R2, E | E2, A>
+  <A, X extends A, R2, E2, _>(f: (a: X) => STM<R2, E2, _>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A>
+  <R, E, A, X extends A, R2, E2, _>(self: STM<R, E, A>, f: (a: X) => STM<R2, E2, _>): STM<R | R2, E | E2, A>
 } = stm.tap
@@ -1791,14 +1820,8 @@
 export const tapBoth: {
-  <E, R2, E2, A2, A, R3, E3, A3>(
-    options: {
-      readonly onFailure: (error: E) => STM<R2, E2, A2>
-      readonly onSuccess: (value: A) => STM<R3, E3, A3>
-    }
+  <E, XE extends E, R2, E2, A2, A, XA extends A, R3, E3, A3>(
+    options: { readonly onFailure: (error: XE) => STM<R2, E2, A2>; readonly onSuccess: (value: XA) => STM<R3, E3, A3> }
   ): <R>(self: STM<R, E, A>) => STM<R2 | R3 | R, E | E2 | E3, A>
-  <R, E, R2, E2, A2, A, R3, E3, A3>(
+  <R, E, XE extends E, R2, E2, A2, A, XA extends A, R3, E3, A3>(
     self: STM<R, E, A>,
-    options: {
-      readonly onFailure: (error: E) => STM<R2, E2, A2>
-      readonly onSuccess: (value: A) => STM<R3, E3, A3>
-    }
+    options: { readonly onFailure: (error: XE) => STM<R2, E2, A2>; readonly onSuccess: (value: XA) => STM<R3, E3, A3> }
   ): STM<R | R2 | R3, E | E2 | E3, A>
@@ -1814,8 +1837,7 @@ } = stm.tapBoth
 export const tapError: {
-  <E, R2, E2, _>(f: (error: E) => STM<R2, E2, _>): <R, A>(self: STM<R, E, A>) => STM<R2 | R, E | E2, A>
-  <R, A, E, R2, E2, _>(self: STM<R, E, A>, f: (error: E) => STM<R2, E2, _>): STM<R | R2, E | E2, A>
+  <E, X extends E, R2, E2, _>(f: (error: X) => STM<R2, E2, _>): <R, A>(self: STM<R, E, A>) => STM<R2 | R, E | E2, A>
+  <R, A, E, X extends E, R2, E2, _>(self: STM<R, E, A>, f: (error: X) => STM<R2, E2, _>): STM<R | R2, E | E2, A>
 } = stm.tapError
 
 const try_: {
-  <A>(try_: LazyArg<A>): STM<never, unknown, A>
   <A, E>(options: {
@@ -1825,2 +1847,3 @@ readonly try: LazyArg<A>
   }): STM<never, E, A>
+  <A>(try_: LazyArg<A>): STM<never, unknown, A>
 } = stm.try_
@@ -1827,0 +1850,0 @@ export {

STM.d.ts

@@ -7,3 +7,3 @@ import type * as Context from "@effect/data/Context";
 import type { Pipeable } from "@effect/data/Pipeable";
-import type { Predicate } from "@effect/data/Predicate";
+import type { Predicate, Refinement } from "@effect/data/Predicate";
 import type * as Unify from "@effect/data/Unify";
@@ -424,3 +424,3 @@ import * as Cause from "@effect/io/Cause";
  */
-export declare const contramapContext: {
+export declare const mapInputContext: {
     <R0, R>(f: (context: Context.Context<R0>) => Context.Context<R>): <E, A>(self: STM<R, E, A>) => STM<R0, E, A>;
@@ -549,4 +549,6 @@ <E, A, R0, R>(self: STM<R, E, A>, f: (context: Context.Context<R0>) => Context.Context<R>): STM<R0, E, A>;
 export declare const filterOrDie: {
-    <A>(predicate: Predicate<A>, defect: LazyArg<unknown>): <R, E>(self: STM<R, E, A>) => STM<R, E, A>;
-    <R, E, A>(self: STM<R, E, A>, predicate: Predicate<A>, defect: LazyArg<unknown>): STM<R, E, A>;
+    <A, B extends A>(refinement: Refinement<A, B>, defect: LazyArg<unknown>): <R, E>(self: STM<R, E, A>) => STM<R, E, B>;
+    <A, X extends A>(predicate: Predicate<X>, defect: LazyArg<unknown>): <R, E>(self: STM<R, E, A>) => STM<R, E, A>;
+    <R, E, A, B extends A>(self: STM<R, E, A>, refinement: Refinement<A, B>, defect: LazyArg<unknown>): STM<R, E, B>;
+    <R, E, A, X extends A>(self: STM<R, E, A>, predicate: Predicate<X>, defect: LazyArg<unknown>): STM<R, E, A>;
 };
@@ -561,4 +563,6 @@ /**
 export declare const filterOrDieMessage: {
-    <A>(predicate: Predicate<A>, message: string): <R, E>(self: STM<R, E, A>) => STM<R, E, A>;
-    <R, E, A>(self: STM<R, E, A>, predicate: Predicate<A>, message: string): STM<R, E, A>;
+    <A, B extends A>(refinement: Refinement<A, B>, message: string): <R, E>(self: STM<R, E, A>) => STM<R, E, B>;
+    <A, X extends A>(predicate: Predicate<X>, message: string): <R, E>(self: STM<R, E, A>) => STM<R, E, A>;
+    <R, E, A, B extends A>(self: STM<R, E, A>, refinement: Refinement<A, B>, message: string): STM<R, E, B>;
+    <R, E, A, X extends A>(self: STM<R, E, A>, predicate: Predicate<X>, message: string): STM<R, E, A>;
 };
@@ -572,4 +576,6 @@ /**
 export declare const filterOrElse: {
-    <A, R2, E2, A2>(predicate: Predicate<A>, orElse: (a: A) => STM<R2, E2, A2>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A | A2>;
-    <R, E, A, R2, E2, A2>(self: STM<R, E, A>, predicate: Predicate<A>, orElse: (a: A) => STM<R2, E2, A2>): STM<R | R2, E | E2, A | A2>;
+    <A, B extends A, X extends A, R2, E2, A2>(refinement: Refinement<A, B>, orElse: (a: X) => STM<R2, E2, A2>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, B | A2>;
+    <A, X extends A, Y extends A, R2, E2, A2>(predicate: Predicate<X>, orElse: (a: Y) => STM<R2, E2, A2>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A | A2>;
+    <R, E, A, B extends A, X extends A, R2, E2, A2>(self: STM<R, E, A>, refinement: Refinement<A, B>, orElse: (a: X) => STM<R2, E2, A2>): STM<R | R2, E | E2, B | A2>;
+    <R, E, A, X extends A, Y extends A, R2, E2, A2>(self: STM<R, E, A>, predicate: Predicate<X>, orElse: (a: Y) => STM<R2, E2, A2>): STM<R | R2, E | E2, A | A2>;
 };
@@ -583,4 +589,6 @@ /**
 export declare const filterOrFail: {
-    <A, E2>(predicate: Predicate<A>, orFailWith: (a: A) => E2): <R, E>(self: STM<R, E, A>) => STM<R, E2 | E, A>;
-    <R, E, A, E2>(self: STM<R, E, A>, predicate: Predicate<A>, orFailWith: (a: A) => E2): STM<R, E | E2, A>;
+    <A, B extends A, X extends A, E2>(refinement: Refinement<A, B>, orFailWith: (a: X) => E2): <R, E>(self: STM<R, E, A>) => STM<R, E2 | E, B>;
+    <A, X extends A, Y extends A, E2>(predicate: Predicate<X>, orFailWith: (a: Y) => E2): <R, E>(self: STM<R, E, A>) => STM<R, E2 | E, A>;
+    <R, E, A, B extends A, X extends A, E2>(self: STM<R, E, A>, refinement: Refinement<A, B>, orFailWith: (a: X) => E2): STM<R, E | E2, B>;
+    <R, E, A, X extends A, Y extends A, E2>(self: STM<R, E, A>, predicate: Predicate<X>, orFailWith: (a: Y) => E2): STM<R, E | E2, A>;
 };
@@ -1318,4 +1326,4 @@ /**
 export declare const tap: {
-    <A, R2, E2, _>(f: (a: A) => STM<R2, E2, _>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A>;
-    <R, E, A, R2, E2, _>(self: STM<R, E, A>, f: (a: A) => STM<R2, E2, _>): STM<R | R2, E | E2, A>;
+    <A, X extends A, R2, E2, _>(f: (a: X) => STM<R2, E2, _>): <R, E>(self: STM<R, E, A>) => STM<R2 | R, E2 | E, A>;
+    <R, E, A, X extends A, R2, E2, _>(self: STM<R, E, A>, f: (a: X) => STM<R2, E2, _>): STM<R | R2, E | E2, A>;
 };
@@ -1329,9 +1337,9 @@ /**
 export declare const tapBoth: {
-    <E, R2, E2, A2, A, R3, E3, A3>(options: {
-        readonly onFailure: (error: E) => STM<R2, E2, A2>;
-        readonly onSuccess: (value: A) => STM<R3, E3, A3>;
+    <E, XE extends E, R2, E2, A2, A, XA extends A, R3, E3, A3>(options: {
+        readonly onFailure: (error: XE) => STM<R2, E2, A2>;
+        readonly onSuccess: (value: XA) => STM<R3, E3, A3>;
     }): <R>(self: STM<R, E, A>) => STM<R2 | R3 | R, E | E2 | E3, A>;
-    <R, E, R2, E2, A2, A, R3, E3, A3>(self: STM<R, E, A>, options: {
-        readonly onFailure: (error: E) => STM<R2, E2, A2>;
-        readonly onSuccess: (value: A) => STM<R3, E3, A3>;
+    <R, E, XE extends E, R2, E2, A2, A, XA extends A, R3, E3, A3>(self: STM<R, E, A>, options: {
+        readonly onFailure: (error: XE) => STM<R2, E2, A2>;
+        readonly onSuccess: (value: XA) => STM<R3, E3, A3>;
     }): STM<R | R2 | R3, E | E2 | E3, A>;
@@ -1346,7 +1354,6 @@ };
 export declare const tapError: {
-    <E, R2, E2, _>(f: (error: E) => STM<R2, E2, _>): <R, A>(self: STM<R, E, A>) => STM<R2 | R, E | E2, A>;
-    <R, A, E, R2, E2, _>(self: STM<R, E, A>, f: (error: E) => STM<R2, E2, _>): STM<R | R2, E | E2, A>;
+    <E, X extends E, R2, E2, _>(f: (error: X) => STM<R2, E2, _>): <R, A>(self: STM<R, E, A>) => STM<R2 | R, E | E2, A>;
+    <R, A, E, X extends E, R2, E2, _>(self: STM<R, E, A>, f: (error: X) => STM<R2, E2, _>): STM<R | R2, E | E2, A>;
 };
 declare const try_: {
-    <A>(try_: LazyArg<A>): STM<never, unknown, A>;
     <A, E>(options: {
@@ -1356,2 +1363,3 @@ readonly try: LazyArg<A>;
     }): STM<never, E, A>;
+    <A>(try_: LazyArg<A>): STM<never, unknown, A>;
 };
@@ -1358,0 +1366,0 @@ export {

STM.js

@@ -6,3 +6,3 @@ "use strict";
 });
-exports.retryUntil = exports.retry = exports.replicateSTMDiscard = exports.replicateSTM = exports.replicate = exports.repeatWhile = exports.repeatUntil = exports.rejectSTM = exports.reject = exports.refineOrDieWith = exports.refineOrDie = exports.reduceRight = exports.reduceAll = exports.reduce = exports.provideSomeContext = exports.provideServiceSTM = exports.provideService = exports.provideContext = exports.partition = exports.orTry = exports.orElseSucceed = exports.orElseOptional = exports.orElseFail = exports.orElseEither = exports.orElse = exports.orDieWith = exports.orDie = exports.option = exports.none = exports.negate = exports.mergeAll = exports.merge = exports.matchSTM = exports.match = exports.mapError = exports.mapBoth = exports.mapAttempt = exports.map = exports.loop = exports.let = exports.iterate = exports.isSuccess = exports.isSTM = exports.isFailure = exports.interruptAs = exports.interrupt = exports.ignore = exports.if = exports.head = exports.gen = exports.fromOption = exports.fromEither = exports.forEach = exports.flipWith = exports.flip = exports.flatten = exports.flatMap = exports.firstSuccessOf = exports.filterOrFail = exports.filterOrElse = exports.filterOrDieMessage = exports.filterOrDie = exports.filterNot = exports.filter = exports.fiberId = exports.failSync = exports.fail = exports.exists = exports.every = exports.eventually = exports.ensuring = exports.either = exports.dieSync = exports.dieMessage = exports.die = exports.contramapContext = exports.contextWithSTM = exports.contextWith = exports.context = exports.cond = exports.commitEither = exports.commit = exports.collectSTM = exports.collect = exports.check = exports.catchTags = exports.catchTag = exports.catchSome = exports.catchAll = exports.bindTo = exports.bind = exports.attempt = exports.asUnit = exports.asSomeError = exports.asSome = exports.as = exports.all = exports.acquireUseRelease = exports.STMTypeId = exports.Do = void 0;
+exports.retryUntil = exports.retry = exports.replicateSTMDiscard = exports.replicateSTM = exports.replicate = exports.repeatWhile = exports.repeatUntil = exports.rejectSTM = exports.reject = exports.refineOrDieWith = exports.refineOrDie = exports.reduceRight = exports.reduceAll = exports.reduce = exports.provideSomeContext = exports.provideServiceSTM = exports.provideService = exports.provideContext = exports.partition = exports.orTry = exports.orElseSucceed = exports.orElseOptional = exports.orElseFail = exports.orElseEither = exports.orElse = exports.orDieWith = exports.orDie = exports.option = exports.none = exports.negate = exports.mergeAll = exports.merge = exports.matchSTM = exports.match = exports.mapInputContext = exports.mapError = exports.mapBoth = exports.mapAttempt = exports.map = exports.loop = exports.let = exports.iterate = exports.isSuccess = exports.isSTM = exports.isFailure = exports.interruptAs = exports.interrupt = exports.ignore = exports.if = exports.head = exports.gen = exports.fromOption = exports.fromEither = exports.forEach = exports.flipWith = exports.flip = exports.flatten = exports.flatMap = exports.firstSuccessOf = exports.filterOrFail = exports.filterOrElse = exports.filterOrDieMessage = exports.filterOrDie = exports.filterNot = exports.filter = exports.fiberId = exports.failSync = exports.fail = exports.exists = exports.every = exports.eventually = exports.ensuring = exports.either = exports.dieSync = exports.dieMessage = exports.die = exports.contextWithSTM = exports.contextWith = exports.context = exports.cond = exports.commitEither = exports.commit = exports.collectSTM = exports.collect = exports.check = exports.catchTags = exports.catchTag = exports.catchSome = exports.catchAll = exports.bindTo = exports.bind = exports.attempt = exports.asUnit = exports.asSomeError = exports.asSome = exports.as = exports.all = exports.acquireUseRelease = exports.STMTypeId = exports.Do = void 0;
 exports.zipWith = exports.zipRight = exports.zipLeft = exports.zip = exports.whenSTM = exports.when = exports.validateFirst = exports.validateAll = exports.unsome = exports.unlessSTM = exports.unless = exports.unit = exports.try = exports.tapError = exports.tapBoth = exports.tap = exports.sync = exports.suspend = exports.summarized = exports.succeedSome = exports.succeedNone = exports.succeed = exports.some = exports.retryWhile = void 0;
@@ -211,3 +211,3 @@ var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
 exports.contextWithSTM = contextWithSTM;
-const contramapContext = core.contramapContext;
+const mapInputContext = core.mapInputContext;
 /**
@@ -219,3 +219,3 @@ * Fails the transactional effect with the specified defect.
  */
-exports.contramapContext = contramapContext;
+exports.mapInputContext = mapInputContext;
 const die = core.die;
@@ -222,0 +222,0 @@ /**

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

Improved metrics

Total package byte prevSize

1592546

increased by0.46%

Lines of code

28048

increased by0.35%

Dependency changes

• + Added@effect/io@0.34.0(transitive)

• - Removed@effect/io@0.33.0(transitive)

• Updated@effect/data@^0.15.1

• Updated@effect/io@^0.34.0