@effect/io - npm Package Compare versions

Comparing version 0.40.1 to 0.40.3

FiberRefs.d.ts

@@ -131,2 +131,9 @@ /**
 export declare const unsafeMake: (fiberRefLocals: Map<FiberRef.FiberRef<any>, Arr.NonEmptyReadonlyArray<readonly [FiberId.Runtime, any]>>) => FiberRefs;
+/**
+ * The empty collection of `FiberRef` values.
+ *
+ * @category constructors
+ * @since 1.0.0
+ */
+export declare const empty: () => FiberRefs;
 //# sourceMappingURL=FiberRefs.d.ts.map

FiberRefs.js

@@ -6,3 +6,3 @@ "use strict";
 });
-exports.updatedAs = exports.unsafeMake = exports.setAll = exports.joinAs = exports.getOrDefault = exports.get = exports.forkAs = exports.fiberRefs = exports.delete = exports.FiberRefsSym = void 0;
+exports.updatedAs = exports.unsafeMake = exports.setAll = exports.joinAs = exports.getOrDefault = exports.get = exports.forkAs = exports.fiberRefs = exports.empty = exports.delete = exports.FiberRefsSym = void 0;
 var internal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberRefs"));
@@ -88,3 +88,11 @@ 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); }
 const unsafeMake = internal.unsafeMake;
+/**
+ * The empty collection of `FiberRef` values.
+ *
+ * @category constructors
+ * @since 1.0.0
+ */
 exports.unsafeMake = unsafeMake;
+const empty = internal.empty;
+exports.empty = empty;
 //# sourceMappingURL=FiberRefs.js.map

internal/fiberRefs.js

@@ -6,3 +6,5 @@ "use strict";
 });
-exports.setAll = exports.joinAs = exports.getOrDefault = exports.get = exports.forkAs = exports.fiberRefs = exports.delete_ = exports.FiberRefsSym = exports.FiberRefsImpl = void 0;
+exports.delete_ = exports.FiberRefsSym = exports.FiberRefsImpl = void 0;
+exports.empty = empty;
+exports.setAll = exports.joinAs = exports.getOrDefault = exports.get = exports.forkAs = exports.fiberRefs = void 0;
 exports.unsafeMake = unsafeMake;
@@ -25,2 +27,6 @@ exports.updatedAs = void 0;
 /** @internal */
+function empty() {
+  return unsafeMake(new Map());
+}
+/** @internal */
 const FiberRefsSym = /*#__PURE__*/Symbol.for("@effect/io/FiberRefs");
@@ -27,0 +33,0 @@ /** @internal */

internal/hub.js

@@ -149,3 +149,3 @@ "use strict";
     while (this.publisherIndex !== publishAllIndex) {
-      const a = Chunk.unsafeGet(iteratorIndex++)(chunk);
+      const a = Chunk.unsafeGet(chunk, iteratorIndex++);
       const index = this.publisherIndex % this.capacity;
@@ -156,3 +156,3 @@ this.array[index] = a;
     }
-    return Chunk.drop(iteratorIndex - 1)(chunk);
+    return Chunk.drop(chunk, iteratorIndex);
   }
@@ -295,3 +295,3 @@ slide() {
     while (this.publisherIndex !== publishAllIndex) {
-      const elem = Chunk.unsafeGet(iteratorIndex++)(chunk);
+      const elem = Chunk.unsafeGet(chunk, iteratorIndex++);
       const index = this.publisherIndex & this.mask;
@@ -302,3 +302,3 @@ this.array[index] = elem;
     }
-    return Chunk.drop(iteratorIndex - 1)(chunk);
+    return Chunk.drop(chunk, iteratorIndex);
   }
@@ -432,3 +432,3 @@ slide() {
     if (this.publish(Chunk.unsafeHead(chunk))) {
-      return Chunk.drop(1)(chunk);
+      return Chunk.drop(chunk, 1);
     } else {
@@ -435,0 +435,0 @@ return chunk;

internal/logger-circular.js

@@ -22,3 +22,3 @@ "use strict";
   cause: Cause.empty,
-  context: fiberRefs.unsafeMake(new Map()),
+  context: fiberRefs.empty(),
   spans: List.empty(),
@@ -25,0 +25,0 @@ annotations: HashMap.empty(),

internal/runtime.js

@@ -246,3 +246,3 @@ "use strict";
   runtimeFlags: defaultRuntimeFlags,
-  fiberRefs: /*#__PURE__*/FiberRefs.unsafeMake( /*#__PURE__*/new Map())
+  fiberRefs: /*#__PURE__*/FiberRefs.empty()
 });
@@ -249,0 +249,0 @@ /** @internal */

package.json

 {
   "name": "@effect/io",
-  "version": "0.40.1",
+  "version": "0.40.3",
   "description": "Functional programming in TypeScript",
@@ -5,0 +5,0 @@ "license": "MIT",

Queue.d.ts

@@ -435,3 +435,3 @@ /**
 export declare const offerAll: {
-    <A>(iterable: Iterable<A>): (self: Enqueue<A>) => (self: Enqueue<A>) => Effect.Effect<never, never, boolean>;
+    <A>(iterable: Iterable<A>): (self: Enqueue<A>) => Effect.Effect<never, never, boolean>;
     <A>(self: Enqueue<A>, iterable: Iterable<A>): Effect.Effect<never, never, boolean>;
@@ -438,0 +438,0 @@ };

src/FiberRefs.ts

@@ -153,1 +153,9 @@ /**
 ) => FiberRefs = internal.unsafeMake
+
+/**
+ * The empty collection of `FiberRef` values.
+ *
+ * @category constructors
+ * @since 1.0.0
+ */
+export const empty: () => FiberRefs = internal.empty

src/internal/fiberRefs.ts

@@ -21,2 +21,7 @@ import * as Equal from "@effect/data/Equal"
 /** @internal */
+export function empty(): FiberRefs.FiberRefs {
+  return unsafeMake(new Map())
+}
+
+/** @internal */
 export const FiberRefsSym: FiberRefs.FiberRefsSym = Symbol.for("@effect/io/FiberRefs") as FiberRefs.FiberRefsSym
@@ -23,0 +28,0 @@

src/internal/hub.ts

@@ -244,3 +244,3 @@ import * as Chunk from "@effect/data/Chunk"
     while (this.publisherIndex !== publishAllIndex) {
-      const a = pipe(chunk, Chunk.unsafeGet(iteratorIndex++))
+      const a = Chunk.unsafeGet(chunk, iteratorIndex++)
       const index = this.publisherIndex % this.capacity
@@ -251,3 +251,3 @@ this.array[index] = a
     }
-    return pipe(chunk, Chunk.drop(iteratorIndex - 1))
+    return Chunk.drop(chunk, iteratorIndex)
   }
@@ -412,3 +412,3 @@
     while (this.publisherIndex !== publishAllIndex) {
-      const elem = pipe(chunk, Chunk.unsafeGet(iteratorIndex++))
+      const elem = Chunk.unsafeGet(chunk, iteratorIndex++)
       const index = this.publisherIndex & this.mask
@@ -419,3 +419,3 @@ this.array[index] = elem
     }
-    return pipe(chunk, Chunk.drop(iteratorIndex - 1))
+    return Chunk.drop(chunk, iteratorIndex)
   }
@@ -568,3 +568,3 @@
     if (this.publish(Chunk.unsafeHead(chunk))) {
-      return pipe(chunk, Chunk.drop(1))
+      return Chunk.drop(chunk, 1)
     } else {
@@ -571,0 +571,0 @@ return chunk

src/internal/logger-circular.ts

@@ -20,3 +20,3 @@ import { dual } from "@effect/data/Function"
     cause: Cause.empty,
-    context: fiberRefs.unsafeMake(new Map()),
+    context: fiberRefs.empty(),
     spans: List.empty(),
@@ -23,0 +23,0 @@ annotations: HashMap.empty(),

src/internal/queue.ts

@@ -458,3 +458,3 @@ import * as Chunk from "@effect/data/Chunk"
     iterable: Iterable<A>
-  ) => (self: Queue.Enqueue<A>) => (self: Queue.Enqueue<A>) => Effect.Effect<never, never, boolean>,
+  ) => (self: Queue.Enqueue<A>) => Effect.Effect<never, never, boolean>,
   <A>(
@@ -461,0 +461,0 @@ self: Queue.Enqueue<A>,

src/internal/runtime.ts

@@ -302,3 +302,3 @@ import * as Context from "@effect/data/Context"
   runtimeFlags: defaultRuntimeFlags,
-  fiberRefs: FiberRefs.unsafeMake(new Map())
+  fiberRefs: FiberRefs.empty()
 })
@@ -305,0 +305,0 @@

src/Queue.ts

@@ -509,3 +509,3 @@ /**
 export const offerAll: {
-  <A>(iterable: Iterable<A>): (self: Enqueue<A>) => (self: Enqueue<A>) => Effect.Effect<never, never, boolean>
+  <A>(iterable: Iterable<A>): (self: Enqueue<A>) => Effect.Effect<never, never, boolean>
   <A>(self: Enqueue<A>, iterable: Iterable<A>): Effect.Effect<never, never, boolean>
@@ -512,0 +512,0 @@ } = internal.offerAll

No alert changes

Improved metrics

Total package byte prevSize

6579074

increased by0.01%

Lines of code

117567

increased by0.04%

No dependency changes