@effect/stm - npm Package Compare versions

Comparing version 0.1.1 to 0.1.2

internal_effect_untraced/core.js

@@ -25,4 +25,4 @@ "use strict";
 var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var MRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/MutableRef"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var MRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/MutableRef"));
 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); }
@@ -54,3 +54,3 @@ 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; }
     const stm = Object.create(proto);
-    stm._stmTag = "Traced";
+    stm._stmTag = OpCodes.OP_TRACED;
     stm.stm = this;
@@ -75,3 +75,3 @@ stm.trace = trace;
   switch (commitResult._tag) {
-    case "Done":
+    case TryCommitOpCodes.OP_DONE:
       {
@@ -81,3 +81,3 @@ onDone(commitResult.exit);
       }
-    case "Suspend":
+    case TryCommitOpCodes.OP_SUSPEND:
       {
@@ -111,9 +111,9 @@ const txnId = TxnId.make();
   const analysis = Journal.analyzeJournal(journal);
-  if (analysis === "ReadWrite") {
+  if (analysis === Journal.JournalAnalysisReadWrite) {
     Journal.commitJournal(journal);
-  } else if (analysis === "Invalid") {
+  } else if (analysis === Journal.JournalAnalysisInvalid) {
     throw new Error("BUG: STM.TryCommit.tryCommit - please report an issue at https://github.com/Effect-TS/io/issues");
   }
   switch (tExit._tag) {
-    case "Succeed":
+    case TExitOpCodes.OP_SUCCEED:
       {
@@ -123,3 +123,3 @@ state.value = STMState.fromTExit(tExit);
       }
-    case "Fail":
+    case TExitOpCodes.OP_FAIL:
       {
@@ -130,3 +130,3 @@ state.value = STMState.fromTExit(tExit);
       }
-    case "Die":
+    case TExitOpCodes.OP_DIE:
       {
@@ -137,3 +137,3 @@ state.value = STMState.fromTExit(tExit);
       }
-    case "Interrupt":
+    case TExitOpCodes.OP_INTERRUPT:
       {
@@ -144,3 +144,3 @@ state.value = STMState.fromTExit(tExit);
       }
-    case "Retry":
+    case TExitOpCodes.OP_RETRY:
       {
@@ -156,13 +156,13 @@ return TryCommit.suspend(journal);
   const analysis = Journal.analyzeJournal(journal);
-  if (analysis === "ReadWrite" && TExit.isSuccess(tExit)) {
+  if (analysis === Journal.JournalAnalysisReadWrite && TExit.isSuccess(tExit)) {
     Journal.commitJournal(journal);
-  } else if (analysis === "Invalid") {
+  } else if (analysis === Journal.JournalAnalysisInvalid) {
     throw new Error("BUG: STM.TryCommit.tryCommitSync - please report an issue at https://github.com/Effect-TS/io/issues");
   }
   switch (tExit._tag) {
-    case "Succeed":
+    case TExitOpCodes.OP_SUCCEED:
       {
         return completeTodos(Exit.succeed(tExit.value), journal, scheduler);
       }
-    case "Fail":
+    case TExitOpCodes.OP_FAIL:
       {
@@ -172,3 +172,3 @@ const cause = Cause.fail(tExit.error);
       }
-    case "Die":
+    case TExitOpCodes.OP_DIE:
       {
@@ -178,3 +178,3 @@ const cause = Cause.die(tExit.defect);
       }
-    case "Interrupt":
+    case TExitOpCodes.OP_INTERRUPT:
       {
@@ -184,3 +184,3 @@ const cause = Cause.interrupt(fiberId);
       }
-    case "Retry":
+    case TExitOpCodes.OP_RETRY:
       {
@@ -196,3 +196,3 @@ return TryCommit.suspend(journal);
     switch (result._tag) {
-      case "Done":
+      case TryCommitOpCodes.OP_DONE:
         {
@@ -202,3 +202,3 @@ completeTryCommit(result.exit, k);
         }
-      case "Suspend":
+      case TryCommitOpCodes.OP_SUSPEND:
         {
@@ -267,3 +267,3 @@ Journal.addTodo(txnId, result.journal, () => tryCommitAsync(fiberId, self, txnId, state, context, scheduler, k));
     let current = this.popStack();
-    while (current !== undefined && current._stmTag !== "OnSuccess") {
+    while (current !== undefined && current._stmTag !== OpCodes.OP_ON_SUCCESS) {
       current = this.popStack();
@@ -275,3 +275,3 @@ }
     let current = this.popStack();
-    while (current !== undefined && current._stmTag !== "OnFailure") {
+    while (current !== undefined && current._stmTag !== OpCodes.OP_ON_FAILURE) {
       current = this.popStack();
@@ -283,3 +283,3 @@ }
     let current = this.popStack();
-    while (current !== undefined && current._stmTag !== "OnRetry") {
+    while (current !== undefined && current._stmTag !== OpCodes.OP_ON_RETRY) {
       current = this.popStack();
@@ -296,3 +296,3 @@ }
         switch (current._stmTag) {
-          case "Traced":
+          case OpCodes.OP_TRACED:
             {
@@ -303,3 +303,3 @@ this.pushStack(current);
             }
-          case "Die":
+          case OpCodes.OP_DIE:
             {
@@ -310,3 +310,3 @@ const annotation = new Cause.StackAnnotation(this.stackToLines(), MRef.incrementAndGet(Cause.globalErrorSeq));
             }
-          case "Fail":
+          case OpCodes.OP_FAIL:
             {
@@ -322,3 +322,3 @@ const annotation = new internalCause.StackAnnotation(this.stackToLines(), MRef.incrementAndGet(Cause.globalErrorSeq));
             }
-          case "Retry":
+          case OpCodes.OP_RETRY:
             {
@@ -333,3 +333,3 @@ const cont = this.nextRetry();
             }
-          case "Interrupt":
+          case OpCodes.OP_INTERRUPT:
             {
@@ -340,3 +340,3 @@ const annotation = new Cause.StackAnnotation(this.stackToLines(), MRef.incrementAndGet(Cause.globalErrorSeq));
             }
-          case "WithSTMRuntime":
+          case OpCodes.OP_WITH_STM_RUNTIME:
             {
@@ -346,5 +346,5 @@ curr = current.evaluate(this);
             }
-          case "OnSuccess":
-          case "OnFailure":
-          case "OnRetry":
+          case OpCodes.OP_ON_SUCCESS:
+          case OpCodes.OP_ON_FAILURE:
+          case OpCodes.OP_ON_RETRY:
             {
@@ -355,3 +355,3 @@ this.pushStack(current);
             }
-          case "Provide":
+          case OpCodes.OP_PROVIDE:
             {
@@ -363,3 +363,3 @@ const env = this.env;
             }
-          case "Succeed":
+          case OpCodes.OP_SUCCEED:
             {
@@ -375,3 +375,3 @@ const value = current.value;
             }
-          case "Sync":
+          case OpCodes.OP_SYNC:
             {
@@ -401,3 +401,3 @@ const value = current.evaluate();
   const stm = Object.create(proto);
-  stm._stmTag = "OnFailure";
+  stm._stmTag = OpCodes.OP_ON_FAILURE;
   stm.first = self;
@@ -427,3 +427,3 @@ stm.failK = restore(f);
   const stm = Object.create(proto);
-  stm._stmTag = "Die";
+  stm._stmTag = OpCodes.OP_DIE;
   stm.defect = restore(evaluate);
@@ -457,3 +457,3 @@ stm.trace = void 0;
   const stm = Object.create(proto);
-  stm._stmTag = "Fail";
+  stm._stmTag = OpCodes.OP_FAIL;
   stm.error = restore(evaluate);
@@ -472,3 +472,3 @@ stm.trace = void 0;
   const stm = Object.create(proto);
-  stm._stmTag = "OnSuccess";
+  stm._stmTag = OpCodes.OP_ON_SUCCESS;
   stm.first = self;
@@ -504,3 +504,3 @@ stm.successK = restore(f);
   const stm = Object.create(proto);
-  stm._stmTag = "Interrupt";
+  stm._stmTag = OpCodes.OP_INTERRUPT;
   stm.fiberId = _.fiberId;
@@ -519,3 +519,3 @@ stm.trace = void 0;
   const stm = Object.create(proto);
-  stm._stmTag = "Interrupt";
+  stm._stmTag = OpCodes.OP_INTERRUPT;
   stm.fiberId = fiberId;
@@ -539,3 +539,3 @@ stm.trace = void 0;
   const stm = Object.create(proto);
-  stm._stmTag = "OnRetry";
+  stm._stmTag = OpCodes.OP_ON_RETRY;
   stm.first = self;
@@ -555,3 +555,3 @@ stm.retryK = restore(that);
   const stm = Object.create(proto);
-  stm._stmTag = "Retry";
+  stm._stmTag = OpCodes.OP_RETRY;
   stm.trace = void 0;
@@ -569,3 +569,3 @@ if (trace) {
   const stm = Object.create(proto);
-  stm._stmTag = "Succeed";
+  stm._stmTag = OpCodes.OP_SUCCEED;
   stm.value = value;
@@ -584,3 +584,3 @@ stm.trace = void 0;
   const stm = Object.create(proto);
-  stm._stmTag = "Sync";
+  stm._stmTag = OpCodes.OP_SYNC;
   stm.evaluate = restore(evaluate);
@@ -599,3 +599,3 @@ stm.trace = void 0;
   const stm = Object.create(proto);
-  stm._stmTag = "Provide";
+  stm._stmTag = OpCodes.OP_PROVIDE;
   stm.stm = self;
@@ -615,3 +615,3 @@ stm.provide = restore(f);
   const stm = Object.create(proto);
-  stm._stmTag = "WithSTMRuntime";
+  stm._stmTag = OpCodes.OP_WITH_STM_RUNTIME;
   stm.evaluate = restore(f);
@@ -618,0 +618,0 @@ stm.trace = void 0;

internal_effect_untraced/stm.js

@@ -20,4 +20,4 @@ "use strict";
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Context"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
 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); }
@@ -24,0 +24,0 @@ 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; }

internal_effect_untraced/stm/stmState.js

@@ -10,5 +10,4 @@ "use strict";
 var TExitOpCodes = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/opCodes/tExit"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
-var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
-var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Hash"));
+var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Equal"));
+var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
 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); }
@@ -28,3 +27,3 @@ 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; }
 const isRunning = self => {
-  return self._tag === "Running";
+  return self._tag === OpCodes.OP_RUNNING;
 };
@@ -34,3 +33,3 @@ /** @internal */
 const isDone = self => {
-  return self._tag === "Done";
+  return self._tag === OpCodes.OP_DONE;
 };
@@ -40,3 +39,3 @@ /** @internal */
 const isInterrupted = self => {
-  return self._tag === "Interrupted";
+  return self._tag === OpCodes.OP_INTERRUPTED;
 };
@@ -48,9 +47,9 @@ /** @internal */
     [STMStateTypeId]: STMStateTypeId,
-    _tag: "Done",
+    _tag: OpCodes.OP_DONE,
     exit,
     [Hash.symbol]() {
-      return Hash.combine(Hash.hash(exit))(Hash.combine(Hash.hash("Done"))(Hash.hash(STMStateSymbolKey)));
+      return Hash.combine(Hash.hash(exit))(Hash.combine(Hash.hash(OpCodes.OP_DONE))(Hash.hash(STMStateSymbolKey)));
     },
     [Equal.symbol](that) {
-      return isSTMState(that) && that._tag === "Done" && Equal.equals(exit, that.exit);
+      return isSTMState(that) && that._tag === OpCodes.OP_DONE && Equal.equals(exit, that.exit);
     }
@@ -63,8 +62,8 @@ };
   [STMStateTypeId]: STMStateTypeId,
-  _tag: "Interrupted",
+  _tag: OpCodes.OP_INTERRUPTED,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash("interrupted"))(Hash.combine(Hash.hash("Interrupted"))(Hash.hash(STMStateSymbolKey)));
+    return Hash.combine(Hash.hash("interrupted"))(Hash.combine(Hash.hash(OpCodes.OP_INTERRUPTED))(Hash.hash(STMStateSymbolKey)));
   },
   [Equal.symbol](that) {
-    return isSTMState(that) && that._tag === "Interrupted";
+    return isSTMState(that) && that._tag === OpCodes.OP_INTERRUPTED;
   }
@@ -76,8 +75,8 @@ };
   [STMStateTypeId]: STMStateTypeId,
-  _tag: "Running",
+  _tag: OpCodes.OP_RUNNING,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash("running"))(Hash.combine(Hash.hash("Running"))(Hash.hash(STMStateSymbolKey)));
+    return Hash.combine(Hash.hash("running"))(Hash.combine(Hash.hash(OpCodes.OP_RUNNING))(Hash.hash(STMStateSymbolKey)));
   },
   [Equal.symbol](that) {
-    return isSTMState(that) && that._tag === "Running";
+    return isSTMState(that) && that._tag === OpCodes.OP_RUNNING;
   }
@@ -89,19 +88,19 @@ };
   switch (tExit._tag) {
-    case "Fail":
+    case TExitOpCodes.OP_FAIL:
       {
         return done(Exit.fail(tExit.error));
       }
-    case "Die":
+    case TExitOpCodes.OP_DIE:
       {
         return done(Exit.die(tExit.defect));
       }
-    case "Interrupt":
+    case TExitOpCodes.OP_INTERRUPT:
       {
         return done(Exit.interrupt(tExit.fiberId));
       }
-    case "Succeed":
+    case TExitOpCodes.OP_SUCCEED:
       {
         return done(Exit.succeed(tExit.value));
       }
-    case "Retry":
+    case TExitOpCodes.OP_RETRY:
       {
@@ -108,0 +107,0 @@ throw new Error("BUG: STM.STMState.fromTExit - please report an issue at https://github.com/Effect-TS/io/issues");

internal_effect_untraced/stm/tExit.js

@@ -8,5 +8,4 @@ "use strict";
 var OpCodes = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/opCodes/tExit"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
-var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
-var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Hash"));
+var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Equal"));
+var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
 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); }
@@ -31,3 +30,3 @@ 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; }
 const isFail = self => {
-  return self._tag === "Fail";
+  return self._tag === OpCodes.OP_FAIL;
 };
@@ -37,3 +36,3 @@ /** @internal */
 const isDie = self => {
-  return self._tag === "Die";
+  return self._tag === OpCodes.OP_DIE;
 };
@@ -43,3 +42,3 @@ /** @internal */
 const isInterrupt = self => {
-  return self._tag === "Interrupt";
+  return self._tag === OpCodes.OP_INTERRUPT;
 };
@@ -49,3 +48,3 @@ /** @internal */
 const isSuccess = self => {
-  return self._tag === "Succeed";
+  return self._tag === OpCodes.OP_SUCCEED;
 };
@@ -55,3 +54,3 @@ /** @internal */
 const isRetry = self => {
-  return self._tag === "Retry";
+  return self._tag === OpCodes.OP_RETRY;
 };
@@ -62,10 +61,10 @@ /** @internal */
   [TExitTypeId]: variance,
-  _tag: "Fail",
+  _tag: OpCodes.OP_FAIL,
   error,
   annotation,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash(error))(Hash.combine(Hash.hash("Fail"))(Hash.hash(TExitSymbolKey)));
+    return Hash.combine(Hash.hash(error))(Hash.combine(Hash.hash(OpCodes.OP_FAIL))(Hash.hash(TExitSymbolKey)));
   },
   [Equal.symbol](that) {
-    return isExit(that) && that._tag === "Fail" && Equal.equals(error, that.error);
+    return isExit(that) && that._tag === OpCodes.OP_FAIL && Equal.equals(error, that.error);
   }
@@ -77,10 +76,10 @@ });
   [TExitTypeId]: variance,
-  _tag: "Die",
+  _tag: OpCodes.OP_DIE,
   defect,
   annotation,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash(defect))(Hash.combine(Hash.hash("Die"))(Hash.hash(TExitSymbolKey)));
+    return Hash.combine(Hash.hash(defect))(Hash.combine(Hash.hash(OpCodes.OP_DIE))(Hash.hash(TExitSymbolKey)));
   },
   [Equal.symbol](that) {
-    return isExit(that) && that._tag === "Die" && Equal.equals(defect, that.defect);
+    return isExit(that) && that._tag === OpCodes.OP_DIE && Equal.equals(defect, that.defect);
   }
@@ -92,10 +91,10 @@ });
   [TExitTypeId]: variance,
-  _tag: "Interrupt",
+  _tag: OpCodes.OP_INTERRUPT,
   fiberId,
   annotation,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash(fiberId))(Hash.combine(Hash.hash("Interrupt"))(Hash.hash(TExitSymbolKey)));
+    return Hash.combine(Hash.hash(fiberId))(Hash.combine(Hash.hash(OpCodes.OP_INTERRUPT))(Hash.hash(TExitSymbolKey)));
   },
   [Equal.symbol](that) {
-    return isExit(that) && that._tag === "Interrupt" && Equal.equals(fiberId, that.fiberId);
+    return isExit(that) && that._tag === OpCodes.OP_INTERRUPT && Equal.equals(fiberId, that.fiberId);
   }
@@ -107,9 +106,9 @@ });
   [TExitTypeId]: variance,
-  _tag: "Succeed",
+  _tag: OpCodes.OP_SUCCEED,
   value,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash(value))(Hash.combine(Hash.hash("Succeed"))(Hash.hash(TExitSymbolKey)));
+    return Hash.combine(Hash.hash(value))(Hash.combine(Hash.hash(OpCodes.OP_SUCCEED))(Hash.hash(TExitSymbolKey)));
   },
   [Equal.symbol](that) {
-    return isExit(that) && that._tag === "Succeed" && Equal.equals(value, that.value);
+    return isExit(that) && that._tag === OpCodes.OP_SUCCEED && Equal.equals(value, that.value);
   }
@@ -121,5 +120,5 @@ });
   [TExitTypeId]: variance,
-  _tag: "Retry",
+  _tag: OpCodes.OP_RETRY,
   [Hash.symbol]() {
-    return Hash.combine(Hash.hash("retry"))(Hash.combine(Hash.hash("Retry"))(Hash.hash(TExitSymbolKey)));
+    return Hash.combine(Hash.hash("retry"))(Hash.combine(Hash.hash(OpCodes.OP_RETRY))(Hash.hash(TExitSymbolKey)));
   },
@@ -126,0 +125,0 @@ [Equal.symbol](that) {

internal_effect_untraced/stm/tryCommit.js

@@ -13,3 +13,3 @@ "use strict";
   return {
-    _tag: "Done",
+    _tag: OpCodes.OP_DONE,
     exit
@@ -22,3 +22,3 @@ };
   return {
-    _tag: "Suspend",
+    _tag: OpCodes.OP_SUSPEND,
     journal
@@ -25,0 +25,0 @@ };

internal_effect_untraced/tArray.js

@@ -11,7 +11,6 @@ "use strict";
 var tRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/tRef"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
 var Order = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/typeclass/Order"));
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Equal"));
 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); }
@@ -18,0 +17,0 @@ 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; }

internal_effect_untraced/tHub.js

@@ -16,4 +16,4 @@ "use strict";
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/HashSet"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/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); }
@@ -85,11 +85,11 @@ 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; }
       switch (this.strategy._tag) {
-        case "BackPressure":
+        case OpCodes.OP_BACKPRESSURE_STRATEGY:
           {
             return core.retry();
           }
-        case "Dropping":
+        case OpCodes.OP_DROPPING_STRATEGY:
           {
             return core.succeed(false);
           }
-        case "Sliding":
+        case OpCodes.OP_SLIDING_STRATEGY:
           {
@@ -96,0 +96,0 @@ if (this.requestedCapacity > 0) {

internal_effect_untraced/tMap.js

@@ -13,8 +13,7 @@ "use strict";
 var STM = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/STM"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
-var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Hash"));
-var HashMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/HashMap"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Equal"));
+var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
+var HashMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/HashMap"));
 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); }
@@ -21,0 +20,0 @@ 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; }

internal_effect_untraced/tPriorityQueue.js

@@ -10,7 +10,6 @@ "use strict";
 var tRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/tRef"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
 var ReadonlyArray = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/ReadonlyArray"));
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var SortedMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/SortedMap"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var SortedMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/SortedMap"));
 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); }
@@ -17,0 +16,0 @@ 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; }

internal_effect_untraced/tQueue.js

@@ -13,5 +13,4 @@ "use strict";
 var STM = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/STM"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
 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); }
@@ -30,3 +29,3 @@ 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; }
 const BackPressure = {
-  _tag: "BackPressure"
+  _tag: OpCodes.OP_BACKPRESSURE_STRATEGY
 };
@@ -36,3 +35,3 @@ /** @internal */
 const Dropping = {
-  _tag: "Dropping"
+  _tag: OpCodes.OP_DROPPING_STRATEGY
 };
@@ -42,3 +41,3 @@ /** @internal */
 const Sliding = {
-  _tag: "Sliding"
+  _tag: OpCodes.OP_SLIDING_STRATEGY
 };
@@ -109,11 +108,11 @@ /** @internal */
       switch (this.strategy._tag) {
-        case "BackPressure":
+        case OpCodes.OP_BACKPRESSURE_STRATEGY:
           {
             return core.retry();
           }
-        case "Dropping":
+        case OpCodes.OP_DROPPING_STRATEGY:
           {
             return core.succeed(false);
           }
-        case "Sliding":
+        case OpCodes.OP_SLIDING_STRATEGY:
           {
@@ -143,7 +142,7 @@ const dequeued = queue.shift();
       switch (this.strategy._tag) {
-        case "BackPressure":
+        case OpCodes.OP_BACKPRESSURE_STRATEGY:
           {
             return core.retry();
           }
-        case "Dropping":
+        case OpCodes.OP_DROPPING_STRATEGY:
           {
@@ -154,3 +153,3 @@ const forQueue = as.slice(0, this.requestedCapacity - queue.length);
           }
-        case "Sliding":
+        case OpCodes.OP_SLIDING_STRATEGY:
           {
@@ -157,0 +156,0 @@ const forQueue = as.slice(0, this.requestedCapacity - queue.length);

internal_effect_untraced/tRandom.js

@@ -13,5 +13,4 @@ "use strict";
 var tRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/tRef"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
-var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Context"));
-var Random = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Random"));
+var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
+var Random = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Random"));
 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); }
@@ -18,0 +17,0 @@ 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; }

internal_effect_untraced/tReentrantLock.js

@@ -12,6 +12,5 @@ "use strict";
 var tRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/tRef"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
-var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));
-var HashMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/HashMap"));
+var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Equal"));
+var HashMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/HashMap"));
 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); }
@@ -18,0 +17,0 @@ 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; }

internal_effect_untraced/tRef.js

@@ -11,3 +11,2 @@ "use strict";
 var Versioned = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/stm/versioned"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/Option"));
@@ -14,0 +13,0 @@ 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); }

internal_effect_untraced/tSemaphore.js

@@ -13,3 +13,2 @@ "use strict";
 var STM = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/STM"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
 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); }
@@ -16,0 +15,0 @@ 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; }

internal_effect_untraced/tSet.js

@@ -10,5 +10,4 @@ "use strict";
 var tMap = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stm/internal_effect_untraced/tMap"));
-var _Function = /*#__PURE__*/require("@fp-ts/core/Function");
-var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
-var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/HashSet"));
+var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/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); }
@@ -15,0 +14,0 @@ 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; }

package.json

 {
   "name": "@effect/stm",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "license": "MIT",
@@ -10,5 +10,5 @@ "repository": {
   "dependencies": {
-    "@effect/io": "~0.1.9",
-    "@fp-ts/core": "~0.1.1",
-    "@fp-ts/data": "~0.1.1"
+    "@effect/data": "^0.0.1",
+    "@effect/io": "~0.1.10",
+    "@fp-ts/core": "~0.1.1"
   },
@@ -15,0 +15,0 @@ "publishConfig": {

src/internal_effect_untraced/core.ts

@@ -23,5 +23,5 @@ import * as Cause from "@effect/io/Cause"
 import { constVoid, pipe } from "@fp-ts/core/Function"
-import * as Chunk from "@fp-ts/data/Chunk"
-import type * as Context from "@fp-ts/data/Context"
-import * as MRef from "@fp-ts/data/MutableRef"
+import * as Chunk from "@effect/data/Chunk"
+import type * as Context from "@effect/data/Context"
+import * as MRef from "@effect/data/MutableRef"
 
@@ -28,0 +28,0 @@ /** @internal */

src/internal_effect_untraced/stm.ts

@@ -19,4 +19,4 @@ import * as Cause from "@effect/io/Cause"
 import type { Predicate } from "@fp-ts/core/Predicate"
-import * as Chunk from "@fp-ts/data/Chunk"
-import * as Context from "@fp-ts/data/Context"
+import * as Chunk from "@effect/data/Chunk"
+import * as Context from "@effect/data/Context"
 
@@ -23,0 +23,0 @@ /**

src/internal_effect_untraced/stm/stmState.ts

@@ -6,4 +6,4 @@ import * as Exit from "@effect/io/Exit"
 import { pipe } from "@fp-ts/core/Function"
-import * as Equal from "@fp-ts/data/Equal"
-import * as Hash from "@fp-ts/data/Hash"
+import * as Equal from "@effect/data/Equal"
+import * as Hash from "@effect/data/Hash"
 
@@ -10,0 +10,0 @@ /** @internal */

src/internal_effect_untraced/stm/tExit.ts

@@ -5,4 +5,4 @@ import type { StackAnnotation } from "@effect/io/Cause"
 import { pipe } from "@fp-ts/core/Function"
-import * as Equal from "@fp-ts/data/Equal"
-import * as Hash from "@fp-ts/data/Hash"
+import * as Equal from "@effect/data/Equal"
+import * as Hash from "@effect/data/Hash"
 
@@ -9,0 +9,0 @@ /** @internal */

src/internal_effect_untraced/tArray.ts

@@ -12,4 +12,4 @@ import * as Debug from "@effect/io/Debug"
 import * as Order from "@fp-ts/core/typeclass/Order"
-import * as Chunk from "@fp-ts/data/Chunk"
-import * as Equal from "@fp-ts/data/Equal"
+import * as Chunk from "@effect/data/Chunk"
+import * as Equal from "@effect/data/Equal"
 
@@ -16,0 +16,0 @@ /** @internal */

src/internal_effect_untraced/tHub.ts

@@ -15,4 +15,4 @@ import * as Debug from "@effect/io/Debug"
 import * as Option from "@fp-ts/core/Option"
-import * as Chunk from "@fp-ts/data/Chunk"
-import * as HashSet from "@fp-ts/data/HashSet"
+import * as Chunk from "@effect/data/Chunk"
+import * as HashSet from "@effect/data/HashSet"
 
@@ -19,0 +19,0 @@ /** @internal */

src/internal_effect_untraced/tMap.ts

@@ -14,6 +14,6 @@ import * as Debug from "@effect/io/Debug"
 import * as Option from "@fp-ts/core/Option"
-import * as Chunk from "@fp-ts/data/Chunk"
-import * as Equal from "@fp-ts/data/Equal"
-import * as Hash from "@fp-ts/data/Hash"
-import * as HashMap from "@fp-ts/data/HashMap"
+import * as Chunk from "@effect/data/Chunk"
+import * as Equal from "@effect/data/Equal"
+import * as Hash from "@effect/data/Hash"
+import * as HashMap from "@effect/data/HashMap"
 
@@ -20,0 +20,0 @@ /** @internal */

src/internal_effect_untraced/tPriorityQueue.ts

@@ -12,4 +12,4 @@ import * as Debug from "@effect/io/Debug"
 import type * as Order from "@fp-ts/core/typeclass/Order"
-import * as Chunk from "@fp-ts/data/Chunk"
-import * as SortedMap from "@fp-ts/data/SortedMap"
+import * as Chunk from "@effect/data/Chunk"
+import * as SortedMap from "@effect/data/SortedMap"
 
@@ -16,0 +16,0 @@ /** @internal */

src/internal_effect_untraced/tQueue.ts

@@ -12,3 +12,3 @@ import * as Debug from "@effect/io/Debug"
 import type { Predicate } from "@fp-ts/core/Predicate"
-import * as Chunk from "@fp-ts/data/Chunk"
+import * as Chunk from "@effect/data/Chunk"
 
@@ -15,0 +15,0 @@ const TEnqueueSymbolKey = "@effect/stm/TQueue/TEnqueue"

src/internal_effect_untraced/tRandom.ts

@@ -12,5 +12,5 @@ import * as Debug from "@effect/io/Debug"
 import { pipe } from "@fp-ts/core/Function"
-import type * as Chunk from "@fp-ts/data/Chunk"
-import * as Context from "@fp-ts/data/Context"
-import * as Random from "@fp-ts/data/Random"
+import type * as Chunk from "@effect/data/Chunk"
+import * as Context from "@effect/data/Context"
+import * as Random from "@effect/data/Random"
 
@@ -17,0 +17,0 @@ const TRandomSymbolKey = "@effect/stm/TRandom"

src/internal_effect_untraced/tReentrantLock.ts

@@ -12,4 +12,4 @@ import * as Debug from "@effect/io/Debug"
 import * as Option from "@fp-ts/core/Option"
-import * as Equal from "@fp-ts/data/Equal"
-import * as HashMap from "@fp-ts/data/HashMap"
+import * as Equal from "@effect/data/Equal"
+import * as HashMap from "@effect/data/HashMap"
 
@@ -16,0 +16,0 @@ const TReentrantLockSymbolKey = "@effect/stm/TReentrantLock"

src/internal_effect_untraced/tSet.ts

@@ -10,4 +10,4 @@ import * as Debug from "@effect/io/Debug"
 import type { Predicate } from "@fp-ts/core/Predicate"
-import * as Chunk from "@fp-ts/data/Chunk"
-import * as HashSet from "@fp-ts/data/HashSet"
+import * as Chunk from "@effect/data/Chunk"
+import * as HashSet from "@effect/data/HashSet"
 
@@ -14,0 +14,0 @@ /** @internal */

src/STM.ts

@@ -16,4 +16,4 @@ /**
 import type { Predicate } from "@fp-ts/core/Predicate"
-import type * as Chunk from "@fp-ts/data/Chunk"
-import type * as Context from "@fp-ts/data/Context"
+import type * as Chunk from "@effect/data/Chunk"
+import type * as Context from "@effect/data/Context"
 
@@ -20,0 +20,0 @@ /**

src/TArray.ts

@@ -10,3 +10,3 @@ /**
 import type * as Order from "@fp-ts/core/typeclass/Order"
-import type * as Chunk from "@fp-ts/data/Chunk"
+import type * as Chunk from "@effect/data/Chunk"
 
@@ -13,0 +13,0 @@ /**

src/THub.ts

@@ -11,3 +11,3 @@ /**
 import type * as TRef from "@effect/stm/TRef"
-import type * as HashSet from "@fp-ts/data/HashSet"
+import type * as HashSet from "@effect/data/HashSet"
 
@@ -14,0 +14,0 @@ /**

src/TMap.ts

@@ -10,4 +10,4 @@ /**
 import type * as Option from "@fp-ts/core/Option"
-import type * as Chunk from "@fp-ts/data/Chunk"
-import type * as HashMap from "@fp-ts/data/HashMap"
+import type * as Chunk from "@effect/data/Chunk"
+import type * as HashMap from "@effect/data/HashMap"
 
@@ -14,0 +14,0 @@ /**

src/TPriorityQueue.ts

@@ -10,4 +10,4 @@ /**
 import type * as Order from "@fp-ts/core/typeclass/Order"
-import type * as Chunk from "@fp-ts/data/Chunk"
-import type * as SortedMap from "@fp-ts/data/SortedMap"
+import type * as Chunk from "@effect/data/Chunk"
+import type * as SortedMap from "@effect/data/SortedMap"
 
@@ -14,0 +14,0 @@ /**

src/TQueue.ts

@@ -8,3 +8,3 @@ /**
 import type { Predicate } from "@fp-ts/core/Predicate"
-import type * as Chunk from "@fp-ts/data/Chunk"
+import type * as Chunk from "@effect/data/Chunk"
 
@@ -11,0 +11,0 @@ /**

src/TRandom.ts

@@ -8,5 +8,5 @@ /**
 import type * as TRef from "@effect/stm/TRef"
-import type * as Chunk from "@fp-ts/data/Chunk"
-import type * as Context from "@fp-ts/data/Context"
-import type * as Random from "@fp-ts/data/Random"
+import type * as Chunk from "@effect/data/Chunk"
+import type * as Context from "@effect/data/Context"
+import type * as Random from "@effect/data/Random"
 
@@ -13,0 +13,0 @@ /**

src/TSet.ts

@@ -9,4 +9,4 @@ /**
 import type { Predicate } from "@fp-ts/core/Predicate"
-import type * as Chunk from "@fp-ts/data/Chunk"
-import type * as HashSet from "@fp-ts/data/HashSet"
+import type * as Chunk from "@effect/data/Chunk"
+import type * as HashSet from "@effect/data/HashSet"
 
@@ -13,0 +13,0 @@ /**

STM.d.ts

@@ -13,4 +13,4 @@ /**
 import type { Predicate } from "@fp-ts/core/Predicate";
-import type * as Chunk from "@fp-ts/data/Chunk";
-import type * as Context from "@fp-ts/data/Context";
+import type * as Chunk from "@effect/data/Chunk";
+import type * as Context from "@effect/data/Context";
 /**
@@ -17,0 +17,0 @@ * @since 1.0.0

TArray.d.ts

@@ -5,3 +5,3 @@ import type * as STM from "@effect/stm/STM";
 import type * as Order from "@fp-ts/core/typeclass/Order";
-import type * as Chunk from "@fp-ts/data/Chunk";
+import type * as Chunk from "@effect/data/Chunk";
 /**
@@ -8,0 +8,0 @@ * @since 1.0.0

TMap.d.ts

 import type * as STM from "@effect/stm/STM";
 import type { LazyArg } from "@fp-ts/core/Function";
 import type * as Option from "@fp-ts/core/Option";
-import type * as Chunk from "@fp-ts/data/Chunk";
-import type * as HashMap from "@fp-ts/data/HashMap";
+import type * as Chunk from "@effect/data/Chunk";
+import type * as HashMap from "@effect/data/HashMap";
 /**
@@ -7,0 +7,0 @@ * @since 1.0.0

TPriorityQueue.d.ts

@@ -5,3 +5,3 @@ import type * as STM from "@effect/stm/STM";
 import type * as Order from "@fp-ts/core/typeclass/Order";
-import type * as Chunk from "@fp-ts/data/Chunk";
+import type * as Chunk from "@effect/data/Chunk";
 /**
@@ -8,0 +8,0 @@ * @since 1.0.0

TQueue.d.ts

 import type * as STM from "@effect/stm/STM";
 import type * as Option from "@fp-ts/core/Option";
 import type { Predicate } from "@fp-ts/core/Predicate";
-import type * as Chunk from "@fp-ts/data/Chunk";
+import type * as Chunk from "@effect/data/Chunk";
 /**
@@ -6,0 +6,0 @@ * @since 1.0.0

TRandom.d.ts

@@ -6,4 +6,4 @@ /**
 import type * as STM from "@effect/stm/STM";
-import type * as Chunk from "@fp-ts/data/Chunk";
-import type * as Context from "@fp-ts/data/Context";
+import type * as Chunk from "@effect/data/Chunk";
+import type * as Context from "@effect/data/Context";
 /**
@@ -10,0 +10,0 @@ * @since 1.0.0

TRef.js

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

tsconfig.base.json

@@ -53,7 +53,3 @@ {
       }
-    ],
-    "transformers": [
-      { "name": "./plugins/tsPlugin.ts", "trace": { "exclude": ["**/*.ts"] } }
-    ],
-    "tsPlusEnabled": false
+    ]
   },
@@ -60,0 +56,0 @@ "include": [],

TSemaphore.js

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

TSet.d.ts

 import type * as STM from "@effect/stm/STM";
 import type * as Option from "@fp-ts/core/Option";
 import type { Predicate } from "@fp-ts/core/Predicate";
-import type * as Chunk from "@fp-ts/data/Chunk";
-import type * as HashSet from "@fp-ts/data/HashSet";
+import type * as Chunk from "@effect/data/Chunk";
+import type * as HashSet from "@effect/data/HashSet";
 /**
@@ -7,0 +7,0 @@ * @since 1.0.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

1650056

increased by0.35%

Worsened metrics

Lines of code

29588

decreased by-0.05%

Dependency changes

• + Added@effect/data@^0.0.1

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

• - Removed@fp-ts/data@~0.1.1

• - Removed@fp-ts/data@0.1.1(transitive)

• Updated@effect/io@~0.1.10