@effect/stream - npm Package Compare versions

Comparing version 0.18.0 to 0.19.0

internal/core.d.ts

@@ -1,6 +0,5 @@
-import type * as Context from "@effect/data/Context";
 import type { LazyArg } from "@effect/data/Function";
 import type * as Channel from "@effect/stream/Channel";
-export type Primitive = BracketOut | Bridge | ConcatAll | Emit | Ensuring | Fail | Fold | FromEffect | PipeTo | Provide | Read | Succeed | SucceedNow | Suspend | Traced | Context.Tag<any, any>;
+export type Primitive = BracketOut | Bridge | ConcatAll | Emit | Ensuring | Fail | Fold | FromEffect | PipeTo | Provide | Read | Succeed | SucceedNow | Suspend | Traced;
 export declare const sync: <OutDone>(evaluate: LazyArg<OutDone>) => Channel.Channel<never, unknown, unknown, unknown, never, never, OutDone>;
 //# sourceMappingURL=core.d.ts.map

internal/sink.js

@@ -9,3 +9,2 @@ "use strict";
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Chunk"));
-var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
 var Duration = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Duration"));
@@ -763,3 +762,3 @@ var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Either"));
 exports.timed = timed;
-const toChannel = self => Context.isGenericTag(self) ? toChannel(fromEffect(self)) : self.channel;
+const toChannel = self => Effect.isEffect(self) ? toChannel(fromEffect(self)) : self.channel;
 /** @internal */
@@ -766,0 +765,0 @@ exports.toChannel = toChannel;

internal/subscriptionRef.js

@@ -33,3 +33,5 @@ "use strict";
     this.semaphore = semaphore;
+    // @ts-ignore
     this[_a] = _ref.refVariance;
+    // @ts-ignore
     this[_b] = _circular.synchronizedVariance;
@@ -36,0 +38,0 @@ this[_c] = subscriptionRefVariance;

package.json

 {
   "name": "@effect/stream",
-  "version": "0.18.0",
+  "version": "0.19.0",
   "license": "MIT",
@@ -10,4 +10,4 @@ "repository": {
   "dependencies": {
-    "@effect/data": "~0.11.5",
-    "@effect/io": "~0.19.2"
+    "@effect/data": "~0.12.2",
+    "@effect/io": "~0.20.0"
   },
@@ -14,0 +14,0 @@ "publishConfig": {

Sink.d.ts

@@ -13,2 +13,3 @@ /**
 import type { Predicate, Refinement } from "@effect/data/Predicate";
+import type * as Unify from "@effect/data/Unify";
 import type * as Cause from "@effect/io/Cause";
@@ -48,6 +49,23 @@ import type * as Effect from "@effect/io/Effect";
  */
-declare module "@effect/data/Context" {
-    interface Tag<Identifier, Service> extends Sink<Identifier, never, unknown, never, Service> {
+export interface SinkUnify<A extends {
+    [Unify.typeSymbol]?: any;
+}> extends Effect.EffectUnify<A> {
+    Sink?: () => A[Unify.typeSymbol] extends Sink<infer R, infer E, infer In, infer L, infer Z> | infer _ ? Sink<R, E, In, L, Z> : never;
+}
+/**
+ * @category models
+ * @since 1.0.0
+ */
+export interface SinkUnifyBlacklist extends Effect.EffectUnifyBlacklist {
+    Sink?: true;
+}
+/**
+ * @since 1.0.0
+ * @category models
+ */
+declare module "@effect/io/Effect" {
+    interface Effect<R, E, A> extends Sink<R, E, unknown, never, A> {
     }
-    interface TracedTag<Identifier, Service> extends Sink<Identifier, never, unknown, never, Service> {
+    interface EffectUnifyBlacklist {
+        Sink?: true;
     }
@@ -686,2 +704,9 @@ }
 /**
+ * Creates a `Channel` from a Sink.
+ *
+ * @since 1.0.0
+ * @category constructors
+ */
+export declare const toChannel: <R, E, In, L, Z>(self: Sink<R, E, In, L, Z>) => Channel.Channel<R, never, Chunk.Chunk<In>, unknown, E, Chunk.Chunk<L>, Z>;
+/**
  * Creates a single-value sink produced from an effect.
@@ -688,0 +713,0 @@ *

Sink.js

@@ -7,3 +7,3 @@ "use strict";
 exports.mapError = exports.mapEffect = exports.map = exports.logWarningCauseMessage = exports.logWarningCause = exports.logWarning = exports.logTraceCauseMessage = exports.logTraceCause = exports.logTrace = exports.logInfoCauseMessage = exports.logInfoCause = exports.logInfo = exports.logFatalCauseMessage = exports.logFatalCause = exports.logFatal = exports.logErrorCauseMessage = exports.logErrorCause = exports.logError = exports.logDebugCauseMessage = exports.logDebugCause = exports.logDebug = exports.log = exports.leftover = exports.last = exports.ignoreLeftover = exports.head = exports.fromQueueWithShutdown = exports.fromQueue = exports.fromPush = exports.fromHubWithShutdown = exports.fromHub = exports.fromEffect = exports.fromChannel = exports.forEachWhile = exports.forEachChunkWhile = exports.forEachChunk = exports.forEach = exports.foldWeightedEffect = exports.foldWeightedDecomposeEffect = exports.foldWeightedDecompose = exports.foldWeighted = exports.foldUntilEffect = exports.foldUntil = exports.foldSink = exports.foldLeftEffect = exports.foldLeftChunksEffect = exports.foldLeftChunks = exports.foldLeft = exports.foldEffect = exports.foldChunksEffect = exports.foldChunks = exports.fold = exports.flatMap = exports.findEffect = exports.filterInputEffect = exports.filterInput = exports.failSync = exports.failCauseSync = exports.failCause = exports.fail = exports.every = exports.ensuringWith = exports.ensuring = exports.dropWhileEffect = exports.dropWhile = exports.dropUntilEffect = exports.dropUntil = exports.drop = exports.drain = exports.dimapEffect = exports.dimapChunksEffect = exports.dimapChunks = exports.dimap = exports.dieSync = exports.dieMessage = exports.die = exports.count = exports.contramapEffect = exports.contramapChunksEffect = exports.contramapChunks = exports.contramap = exports.contextWithSink = exports.contextWithEffect = exports.contextWith = exports.context = exports.collectLeftover = exports.collectAllWhileWith = exports.collectAllWhileEffect = exports.collectAllWhile = exports.collectAllUntilEffect = exports.collectAllUntil = exports.collectAllToSetN = exports.collectAllToSet = exports.collectAllToMapN = exports.collectAllToMap = exports.collectAllN = exports.collectAllFrom = exports.collectAll = exports.as = exports.SinkTypeId = void 0;
-exports.zipWithPar = exports.zipWith = exports.zipRight = exports.zipParRight = exports.zipParLeft = exports.zipPar = exports.zipLeft = exports.zip = exports.withDuration = exports.unwrapScoped = exports.unwrap = exports.timed = exports.take = exports.sync = exports.suspend = exports.summarized = exports.sum = exports.succeed = exports.splitWhere = exports.some = exports.refineOrDieWith = exports.refineOrDie = exports.raceWithCapacity = exports.raceWith = exports.raceBothCapacity = exports.raceBoth = exports.race = exports.provideContext = exports.orElse = exports.never = exports.mkString = exports.mapLeftover = void 0;
+exports.zipWithPar = exports.zipWith = exports.zipRight = exports.zipParRight = exports.zipParLeft = exports.zipPar = exports.zipLeft = exports.zip = exports.withDuration = exports.unwrapScoped = exports.unwrap = exports.toChannel = exports.timed = exports.take = exports.sync = exports.suspend = exports.summarized = exports.sum = exports.succeed = exports.splitWhere = exports.some = exports.refineOrDieWith = exports.refineOrDie = exports.raceWithCapacity = exports.raceWith = exports.raceBothCapacity = exports.raceBoth = exports.race = exports.provideContext = exports.orElse = exports.never = exports.mkString = exports.mapLeftover = void 0;
 var internal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/stream/internal/sink"));
@@ -655,2 +655,10 @@ 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); }
 /**
+ * Creates a `Channel` from a Sink.
+ *
+ * @since 1.0.0
+ * @category constructors
+ */
+exports.fromChannel = fromChannel;
+const toChannel = internal.toChannel;
+/**
  * Creates a single-value sink produced from an effect.
@@ -661,3 +669,3 @@ *
  */
-exports.fromChannel = fromChannel;
+exports.toChannel = toChannel;
 const fromEffect = internal.fromEffect;
@@ -664,0 +672,0 @@ /**

src/internal/core.ts

@@ -81,3 +81,2 @@ import * as Chunk from "@effect/data/Chunk"
   | Traced
-  | Context.Tag<any, any>
 
@@ -84,0 +83,0 @@ /** @internal */

src/internal/subscriptionRef.ts

@@ -28,3 +28,5 @@ import { bodyWithTrace, dualWithTrace, methodWithTrace } from "@effect/data/Debug"
 class SubscriptionRefImpl<A> implements SubscriptionRef.SubscriptionRef<A> {
+  // @ts-ignore
   readonly [Ref.RefTypeId] = _ref.refVariance
+  // @ts-ignore
   readonly [Synchronized.SynchronizedTypeId] = _circular.synchronizedVariance
@@ -31,0 +33,0 @@ readonly [SubscriptionRefTypeId] = subscriptionRefVariance

src/Sink.ts

@@ -13,2 +13,3 @@ /**
 import type { Predicate, Refinement } from "@effect/data/Predicate"
+import type * as Unify from "@effect/data/Unify"
 import type * as Cause from "@effect/io/Cause"
@@ -52,10 +53,37 @@ import type * as Effect from "@effect/io/Effect"
  */
-declare module "@effect/data/Context" {
-  interface Tag<Identifier, Service> extends Sink<Identifier, never, unknown, never, Service> {}
-  interface TracedTag<Identifier, Service> extends Sink<Identifier, never, unknown, never, Service> {}
+export interface SinkUnify<A extends { [Unify.typeSymbol]?: any }> extends Effect.EffectUnify<A> {
+  Sink?: () => A[Unify.typeSymbol] extends
+    | Sink<
+      infer R,
+      infer E,
+      infer In,
+      infer L,
+      infer Z
+    >
+    | infer _ ? Sink<R, E, In, L, Z>
+    : never
 }
 
 /**
+ * @category models
  * @since 1.0.0
  */
+export interface SinkUnifyBlacklist extends Effect.EffectUnifyBlacklist {
+  Sink?: true
+}
+
+/**
+ * @since 1.0.0
+ * @category models
+ */
+declare module "@effect/io/Effect" {
+  interface Effect<R, E, A> extends Sink<R, E, unknown, never, A> {}
+  interface EffectUnifyBlacklist {
+    Sink?: true
+  }
+}
+
+/**
+ * @since 1.0.0
+ */
 export declare namespace Sink {
@@ -914,2 +942,12 @@ /**
 /**
+ * Creates a `Channel` from a Sink.
+ *
+ * @since 1.0.0
+ * @category constructors
+ */
+export const toChannel: <R, E, In, L, Z>(
+  self: Sink<R, E, In, L, Z>
+) => Channel.Channel<R, never, Chunk.Chunk<In>, unknown, E, Chunk.Chunk<L>, Z> = internal.toChannel
+
+/**
  * Creates a single-value sink produced from an effect.
@@ -916,0 +954,0 @@ *

tsconfig.base.json

@@ -41,5 +41,5 @@ {
     "paths": {
-      "@effect/io/*": [
-        "./node_modules/@effect/io/src/*"
-      ],
+      // "@effect/io/*": [
+      //   "./node_modules/@effect/io/src/*"
+      // ],
       "@effect/stream": [
@@ -46,0 +46,0 @@ "./src/index.ts"

tsconfig.json

 {
   "extends": "./tsconfig.base.json",
   "references": [
-    { "path": "./tsconfig.build.json" },
-    { "path": "./tsconfig.test.json" },
-    { "path": "./tsconfig.examples.json" }
+    {
+      "path": "./tsconfig.build.json"
+    },
+    {
+      "path": "./tsconfig.test.json"
+    },
+    {
+      "path": "./tsconfig.examples.json"
+    }
   ]
 }

tsconfig.test.json

@@ -7,5 +7,28 @@ {
     "noEmit": true,
-    "types": ["vitest/globals", "node"]
+    "types": [
+      "vitest/globals",
+      "node"
+    ],
+    "paths": {
+      "@effect/io/*": [
+        "./node_modules/@effect/io/src/*"
+      ],
+      "@effect/stream": [
+        "./src/index.ts"
+      ],
+      "@effect/stream/test/*": [
+        "./test/*"
+      ],
+      "@effect/stream/examples/*": [
+        "./examples/*"
+      ],
+      "@effect/stream/*": [
+        "./src/*"
+      ]
+    }
   },
-  "include": ["test/**/*.ts", "src/**/*.ts"]
+  "include": [
+    "test/**/*.ts",
+    "src/**/*.ts"
+  ]
 }

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

3640128

increased by0.2%

Lines of code

60356

increased by0.35%

Dependency changes

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

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

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

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

• Updated@effect/data@~0.12.2

• Updated@effect/io@~0.20.0