@effect/stream - npm Package Compare versions

Comparing version 0.13.0 to 0.14.0

internal/channel.js

@@ -9,2 +9,3 @@ "use strict";
 var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
+var Debug = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Debug"));
 var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Either"));
@@ -15,3 +16,2 @@ var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Equal"));
 var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
-var Debug = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Debug"));
 var Deferred = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Deferred"));
@@ -398,3 +398,3 @@ var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));
 exports.scoped = scoped;
-const service = /*#__PURE__*/Debug.methodWithTrace(trace => tag => core.fromEffect(Effect.service(tag)).traced(trace));
+const service = /*#__PURE__*/Debug.methodWithTrace(trace => tag => core.fromEffect(tag).traced(trace));
 /** @internal */
@@ -401,0 +401,0 @@ exports.service = service;

internal/channel/channelExecutor.d.ts

 import * as Chunk from "@effect/data/Chunk";
 import type * as Context from "@effect/data/Context";
+import * as Debug from "@effect/data/Debug";
 import * as Option from "@effect/data/Option";
 import * as Cause from "@effect/io/Cause";
-import * as Debug from "@effect/io/Debug";
 import * as Effect from "@effect/io/Effect";
@@ -7,0 +7,0 @@ import * as Exit from "@effect/io/Exit";

internal/channel/channelExecutor.js

@@ -8,2 +8,3 @@ "use strict";
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var Debug = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Debug"));
 var _Function = /*#__PURE__*/require("@effect/data/Function");
@@ -13,3 +14,2 @@ var MRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/MutableRef"));
 var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
-var Debug = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Debug"));
 var Deferred = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Deferred"));
@@ -16,0 +16,0 @@ var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));

internal/channel/singleProducerAsyncInput.js

@@ -7,5 +7,5 @@ "use strict";
 exports.make = void 0;
+var _Debug = /*#__PURE__*/require("@effect/data/Debug");
 var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Either"));
 var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
-var _Debug = /*#__PURE__*/require("@effect/io/Debug");
 var Deferred = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Deferred"));
@@ -12,0 +12,0 @@ var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));

internal/channel/subexecutor.js

@@ -7,3 +7,3 @@ "use strict";
 exports.PullFromUpstream = exports.PullFromChild = exports.OP_PULL_FROM_UPSTREAM = exports.OP_PULL_FROM_CHILD = exports.OP_EMIT = exports.OP_DRAIN_CHILD_EXECUTORS = exports.Emit = exports.DrainChildExecutors = void 0;
-var _Debug = /*#__PURE__*/require("@effect/io/Debug");
+var _Debug = /*#__PURE__*/require("@effect/data/Debug");
 var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));
@@ -10,0 +10,0 @@ var Exit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Exit"));

internal/core.js

@@ -8,2 +8,3 @@ "use strict";
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var Debug = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Debug"));
 var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Either"));
@@ -13,3 +14,2 @@ var _Function = /*#__PURE__*/require("@effect/data/Function");
 var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
-var Debug = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Debug"));
 var childExecutorDecision = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stream/internal/channel/childExecutorDecision"));
@@ -16,0 +16,0 @@ var _continuation = /*#__PURE__*/require("@effect/stream/internal/channel/continuation");

internal/sink.js

@@ -681,9 +681,9 @@ "use strict";
 exports.service = service;
-const serviceWith = (tag, f) => fromEffect(Effect.serviceWith(tag, f));
+const serviceWith = (tag, f) => fromEffect(Effect.map(tag, f));
 /** @internal */
 exports.serviceWith = serviceWith;
-const serviceWithEffect = (tag, f) => fromEffect(Effect.serviceWithEffect(tag, f));
+const serviceWithEffect = (tag, f) => fromEffect(Effect.flatMap(tag, f));
 /** @internal */
 exports.serviceWithEffect = serviceWithEffect;
-const serviceWithSink = (tag, f) => new SinkImpl(channel.unwrap(Effect.serviceWith(tag, service => f(service).channel)));
+const serviceWithSink = (tag, f) => new SinkImpl(channel.unwrap(Effect.map(tag, service => f(service).channel)));
 /** @internal */
@@ -690,0 +690,0 @@ exports.serviceWithSink = serviceWithSink;

internal/stream/handoff.js

@@ -7,4 +7,4 @@ "use strict";
 exports.take = exports.poll = exports.offer = exports.make = exports.OP_HANDOFF_STATE_FULL = exports.OP_HANDOFF_STATE_EMPTY = exports.HandoffTypeId = void 0;
+var _Debug = /*#__PURE__*/require("@effect/data/Debug");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
-var _Debug = /*#__PURE__*/require("@effect/io/Debug");
 var Deferred = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Deferred"));
@@ -11,0 +11,0 @@ var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));

internal/stream/pull.js

@@ -8,4 +8,4 @@ "use strict";
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var _Debug = /*#__PURE__*/require("@effect/data/Debug");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
-var _Debug = /*#__PURE__*/require("@effect/io/Debug");
 var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));
@@ -12,0 +12,0 @@ var Queue = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Queue"));

internal/subscriptionRef.js

@@ -7,3 +7,3 @@ "use strict";
 exports.set = exports.modifyEffect = exports.modify = exports.make = exports.get = exports.SubscriptionRefTypeId = void 0;
-var _Debug = /*#__PURE__*/require("@effect/io/Debug");
+var _Debug = /*#__PURE__*/require("@effect/data/Debug");
 var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));
@@ -10,0 +10,0 @@ var Hub = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Hub"));

internal/take.js

@@ -8,6 +8,6 @@ "use strict";
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
+var _Debug = /*#__PURE__*/require("@effect/data/Debug");
 var _Function = /*#__PURE__*/require("@effect/data/Function");
 var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
 var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
-var _Debug = /*#__PURE__*/require("@effect/io/Debug");
 var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));
@@ -14,0 +14,0 @@ var Exit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Exit"));

package.json

 {
   "name": "@effect/stream",
-  "version": "0.13.0",
+  "version": "0.14.0",
   "license": "MIT",
@@ -10,4 +10,4 @@ "repository": {
   "dependencies": {
-    "@effect/data": "~0.7.1",
-    "@effect/io": "~0.14.1"
+    "@effect/data": "~0.7.4",
+    "@effect/io": "~0.15.1"
   },
@@ -14,0 +14,0 @@ "publishConfig": {

src/internal/channel/channelExecutor.ts

 import * as Chunk from "@effect/data/Chunk"
 import type * as Context from "@effect/data/Context"
+import * as Debug from "@effect/data/Debug"
 import { identity, pipe } from "@effect/data/Function"
@@ -7,3 +8,2 @@ import * as MRef from "@effect/data/MutableRef"
 import * as Cause from "@effect/io/Cause"
-import * as Debug from "@effect/io/Debug"
 import * as Deferred from "@effect/io/Deferred"
@@ -10,0 +10,0 @@ import * as Effect from "@effect/io/Effect"

src/internal/channel/singleProducerAsyncInput.ts

@@ -0,5 +1,5 @@
+import { bodyWithTrace, methodWithTrace } from "@effect/data/Debug"
 import * as Either from "@effect/data/Either"
 import { pipe } from "@effect/data/Function"
 import * as Cause from "@effect/io/Cause"
-import { bodyWithTrace, methodWithTrace } from "@effect/io/Debug"
 import * as Deferred from "@effect/io/Deferred"
@@ -6,0 +6,0 @@ import * as Effect from "@effect/io/Effect"

src/internal/channel/subexecutor.ts

@@ -0,3 +1,3 @@
+import { bodyWithTrace } from "@effect/data/Debug"
 import { pipe } from "@effect/data/Function"
-import { bodyWithTrace } from "@effect/io/Debug"
 import * as Effect from "@effect/io/Effect"
@@ -4,0 +4,0 @@ import * as Exit from "@effect/io/Exit"

src/internal/core.ts

 import * as Chunk from "@effect/data/Chunk"
 import type * as Context from "@effect/data/Context"
+import * as Debug from "@effect/data/Debug"
 import * as Either from "@effect/data/Either"
@@ -8,3 +9,2 @@ import { constVoid, identity } from "@effect/data/Function"
 import * as Cause from "@effect/io/Cause"
-import * as Debug from "@effect/io/Debug"
 import type * as Effect from "@effect/io/Effect"
@@ -11,0 +11,0 @@ import type * as Exit from "@effect/io/Exit"

src/internal/stream/handoff.ts

@@ -0,4 +1,4 @@
+import { dualWithTrace, methodWithTrace } from "@effect/data/Debug"
 import { pipe } from "@effect/data/Function"
 import * as Option from "@effect/data/Option"
-import { dualWithTrace, methodWithTrace } from "@effect/io/Debug"
 import * as Deferred from "@effect/io/Deferred"
@@ -5,0 +5,0 @@ import * as Effect from "@effect/io/Effect"

src/internal/stream/pull.ts

 import * as Chunk from "@effect/data/Chunk"
+import { methodWithTrace } from "@effect/data/Debug"
 import { pipe } from "@effect/data/Function"
 import * as Option from "@effect/data/Option"
 import type * as Cause from "@effect/io/Cause"
-import { methodWithTrace } from "@effect/io/Debug"
 import * as Effect from "@effect/io/Effect"
@@ -7,0 +7,0 @@ import * as Queue from "@effect/io/Queue"

src/internal/subscriptionRef.ts

@@ -0,3 +1,3 @@
+import { bodyWithTrace, dualWithTrace, methodWithTrace } from "@effect/data/Debug"
 import { pipe } from "@effect/data/Function"
-import { bodyWithTrace, dualWithTrace, methodWithTrace } from "@effect/io/Debug"
 import * as Effect from "@effect/io/Effect"
@@ -4,0 +4,0 @@ import * as Hub from "@effect/io/Hub"

src/internal/take.ts

 import * as Chunk from "@effect/data/Chunk"
+import { dualWithTrace, methodWithTrace } from "@effect/data/Debug"
 import { constFalse, constTrue, dual, pipe } from "@effect/data/Function"
 import * as Option from "@effect/data/Option"
 import * as Cause from "@effect/io/Cause"
-import { dualWithTrace, methodWithTrace } from "@effect/io/Debug"
 import * as Effect from "@effect/io/Effect"
@@ -7,0 +7,0 @@ import * as Exit from "@effect/io/Exit"

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

3628770

Dependency changes

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

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

• Updated@effect/data@~0.7.4

• Updated@effect/io@~0.15.1