@effect/stream - npm Package Compare versions

Comparing version 0.35.1 to 0.36.0

package.json

 {
   "name": "@effect/stream",
-  "version": "0.35.1",
+  "version": "0.36.0",
   "description": "Functional programming in TypeScript",
@@ -29,4 +29,4 @@ "license": "MIT",
     "@effect/data": "^0.18.3",
-    "@effect/io": "^0.39.0"
+    "@effect/io": "^0.40.0"
   }
 }

Sink.d.ts

@@ -782,2 +782,3 @@ /**
  *
+ * @param shutdown If `true`, the hub will be shutdown after the sink is evaluated (defaults to `false`)
  * @since 1.0.0
@@ -795,6 +796,7 @@ * @category constructors
  */
-export declare const fromPush: <R, E, In, L, Z>(push: Effect.Effect<Scope.Scope | R, never, (_: Option.Option<Chunk.Chunk<In>>) => Effect.Effect<R, readonly [Either.Either<E, Z>, Chunk.Chunk<L>], void>>) => Sink<R, E, In, L, Z>;
+export declare const fromPush: <R, E, In, L, Z>(push: Effect.Effect<R, never, (_: Option.Option<Chunk.Chunk<In>>) => Effect.Effect<R, readonly [Either.Either<E, Z>, Chunk.Chunk<L>], void>>) => Sink<Exclude<R, Scope.Scope>, E, In, L, Z>;
 /**
  * Create a sink which enqueues each element into the specified queue.
  *
+ * @param shutdown If `true`, the queue will be shutdown after the sink is evaluated (defaults to `false`)
  * @since 1.0.0
@@ -1054,3 +1056,3 @@ * @category constructors
  */
-export declare const unwrapScoped: <R, E, In, L, Z>(effect: Effect.Effect<R | Scope.Scope, E, Sink<R, E, In, L, Z>>) => Sink<R, E, In, L, Z>;
+export declare const unwrapScoped: <R, E, In, L, Z>(effect: Effect.Effect<R, E, Sink<R, E, In, L, Z>>) => Sink<Exclude<R, Scope.Scope>, E, In, L, Z>;
 /**
@@ -1057,0 +1059,0 @@ * Returns the sink that executes this one and times its execution.

Sink.js

@@ -672,2 +672,3 @@ "use strict";
  *
+ * @param shutdown If `true`, the hub will be shutdown after the sink is evaluated (defaults to `false`)
  * @since 1.0.0
@@ -689,2 +690,3 @@ * @category constructors
  *
+ * @param shutdown If `true`, the queue will be shutdown after the sink is evaluated (defaults to `false`)
  * @since 1.0.0
@@ -691,0 +693,0 @@ * @category constructors

src/Sink.ts

@@ -989,2 +989,3 @@ /**
  *
+ * @param shutdown If `true`, the hub will be shutdown after the sink is evaluated (defaults to `false`)
  * @since 1.0.0
@@ -1006,7 +1007,7 @@ * @category constructors
   push: Effect.Effect<
-    Scope.Scope | R,
+    R,
     never,
     (_: Option.Option<Chunk.Chunk<In>>) => Effect.Effect<R, readonly [Either.Either<E, Z>, Chunk.Chunk<L>], void>
   >
-) => Sink<R, E, In, L, Z> = internal.fromPush
+) => Sink<Exclude<R, Scope.Scope>, E, In, L, Z> = internal.fromPush
 
@@ -1016,2 +1017,3 @@ /**
  *
+ * @param shutdown If `true`, the queue will be shutdown after the sink is evaluated (defaults to `false`)
  * @since 1.0.0
@@ -1338,4 +1340,4 @@ * @category constructors
 export const unwrapScoped: <R, E, In, L, Z>(
-  effect: Effect.Effect<R | Scope.Scope, E, Sink<R, E, In, L, Z>>
-) => Sink<R, E, In, L, Z> = internal.unwrapScoped
+  effect: Effect.Effect<R, E, Sink<R, E, In, L, Z>>
+) => Sink<Exclude<R, Scope.Scope>, E, In, L, Z> = internal.unwrapScoped
 
@@ -1342,0 +1344,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

3448076

increased by0.07%

Lines of code

58208

increased by0.03%

No dependency changes