@effect/io - npm Package Compare versions

Comparing version 0.0.35 to 0.0.37

FiberRef.d.ts

@@ -7,2 +7,3 @@ /**
 import type * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
+import type * as Scheduler from "@effect/io/Scheduler";
 import type * as Logger from "@effect/io/Logger";
@@ -241,2 +242,7 @@ import type * as LogLevel from "@effect/io/Logger/Level";
  */
+export declare const currentScheduler: FiberRef<Scheduler.Scheduler>;
+/**
+ * @since 1.0.0
+ * @category fiberRefs
+ */
 export declare const currentSupervisor: FiberRef<Supervisor.Supervisor<any>>;
@@ -243,0 +249,0 @@ /**

FiberRef.js

@@ -6,3 +6,3 @@ "use strict";
 });
-exports.updateSomeAndGet = exports.updateSome = exports.updateAndGet = exports.update = exports.unsafeMakeSupervisor = exports.unsafeMakePatch = exports.unsafeMakeHashSet = exports.unsafeMakeEnvironment = exports.unsafeMake = exports.set = exports.reset = exports.modifySome = exports.modify = exports.makeWith = exports.makeRuntimeFlags = exports.makeEnvironment = exports.make = exports.locallyWith = exports.locallyScopedWith = exports.locallyScoped = exports.locally = exports.interruptedCause = exports.getWith = exports.getAndUpdateSome = exports.getAndUpdate = exports.getAndSet = exports.get = exports.delete = exports.currentSupervisor = exports.currentRuntimeFlags = exports.currentParallelism = exports.currentLoggers = exports.currentLogSpan = exports.currentLogLevel = exports.currentLogAnnotations = exports.currentEnvironment = exports.FiberRefTypeId = void 0;
+exports.updateSomeAndGet = exports.updateSome = exports.updateAndGet = exports.update = exports.unsafeMakeSupervisor = exports.unsafeMakePatch = exports.unsafeMakeHashSet = exports.unsafeMakeEnvironment = exports.unsafeMake = exports.set = exports.reset = exports.modifySome = exports.modify = exports.makeWith = exports.makeRuntimeFlags = exports.makeEnvironment = exports.make = exports.locallyWith = exports.locallyScopedWith = exports.locallyScoped = exports.locally = exports.interruptedCause = exports.getWith = exports.getAndUpdateSome = exports.getAndUpdate = exports.getAndSet = exports.get = exports.delete = exports.currentSupervisor = exports.currentScheduler = exports.currentRuntimeFlags = exports.currentParallelism = exports.currentLoggers = exports.currentLogSpan = exports.currentLogLevel = exports.currentLogAnnotations = exports.currentEnvironment = exports.FiberRefTypeId = void 0;
 var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));
@@ -244,2 +244,8 @@ var fiberRuntime = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberRuntime"));
 exports.currentParallelism = currentParallelism;
+const currentScheduler = core.currentScheduler;
+/**
+ * @since 1.0.0
+ * @category fiberRefs
+ */
+exports.currentScheduler = currentScheduler;
 const currentSupervisor = fiberRuntime.currentSupervisor;
@@ -246,0 +252,0 @@ /**

internal/core.js

@@ -15,3 +15,3 @@ "use strict";
 var _runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
-var Scheduler = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));
+var scheduler = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));
 var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));
@@ -1091,3 +1091,3 @@ var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Context"));
 exports.currentLogSpan = currentLogSpan;
-const currentScheduler = /*#__PURE__*/fiberRefUnsafeMake(Scheduler.defaultScheduler);
+const currentScheduler = /*#__PURE__*/fiberRefUnsafeMake(scheduler.defaultScheduler);
 /** @internal */
@@ -1094,0 +1094,0 @@ exports.currentScheduler = currentScheduler;

internal/effect.d.ts

 import type * as Effect from "@effect/io/Effect";
 import type { MergeRecord } from "@effect/io/internal/types";
-import * as Chunk from "@fp-ts/data/Chunk";
 export declare const bind: <N extends string, K, R2, E2, A>(tag: Exclude<N, keyof K>, f: (_: K) => Effect.Effect<R2, E2, A>) => <R, E>(self: Effect.Effect<R, E, K>) => Effect.Effect<R2 | R, E2 | E, MergeRecord<K, { [k in N]: A; }>>;
-/**
- * Drops all elements so long as the predicate returns true.
- *
- * @macro traced
- * @category constructors
- * @since 1.0.0
- */
-export declare const dropWhile: <R, E, A>(f: (a: A) => Effect.Effect<R, E, boolean>) => (elements: Iterable<A>) => Effect.Effect<R, E, Chunk.Chunk<A>>;
 /** @Internal */
 export declare const flipWith: <R, A, E, R2, A2, E2>(f: (effect: Effect.Effect<R, A, E>) => Effect.Effect<R2, A2, E2>) => (self: Effect.Effect<R, E, A>) => Effect.Effect<R2, E2, A2>;
 //# sourceMappingURL=effect.d.ts.map

internal/runtime.js

@@ -18,3 +18,3 @@ "use strict";
 var runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
-var Scheduler = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));
+var _scheduler = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));
 var _supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/supervisor"));
@@ -71,3 +71,3 @@ var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Context"));
     this.unsafeRunSyncExit = effect => {
-      const scheduler = new Scheduler.SyncScheduler();
+      const scheduler = new _scheduler.SyncScheduler();
       const fiberRuntime = this.unsafeFork(effect, scheduler);
@@ -74,0 +74,0 @@ scheduler.flush();

package.json

 {
   "name": "@effect/io",
-  "version": "0.0.35",
+  "version": "0.0.37",
   "license": "MIT",
@@ -11,3 +11,3 @@ "repository": {
     "@fp-ts/core": "~0.0.9",
-    "@fp-ts/data": "~0.0.25"
+    "@fp-ts/data": "~0.0.26"
   },
@@ -14,0 +14,0 @@ "publishConfig": {

Queue.d.ts

@@ -321,3 +321,3 @@ /**
  */
-export declare const capacity: <A>(self: Queue<A>) => number;
+export declare const capacity: <A>(self: Dequeue<A> | Enqueue<A>) => number;
 /**
@@ -332,3 +332,3 @@ * Retrieves the size of the queue, which is equal to the number of elements
  */
-export declare const size: <A>(self: Queue<A>) => Effect.Effect<never, never, number>;
+export declare const size: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, number>;
 /**
@@ -341,3 +341,3 @@ * Returns `true` if the `Queue` contains zero elements, `false` otherwise.
  */
-export declare const isEmpty: <A>(self: Queue<A>) => Effect.Effect<never, never, boolean>;
+export declare const isEmpty: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, boolean>;
 /**
@@ -351,3 +351,3 @@ * Returns `true` if the `Queue` contains at least one element, `false`
  */
-export declare const isFull: <A>(self: Queue<A>) => Effect.Effect<never, never, boolean>;
+export declare const isFull: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, boolean>;
 /**
@@ -360,3 +360,3 @@ * Returns `true` if `shutdown` has been called, otherwise returns `false`.
  */
-export declare const isShutdown: <A>(self: Queue<A>) => Effect.Effect<never, never, boolean>;
+export declare const isShutdown: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, boolean>;
 /**
@@ -371,3 +371,3 @@ * Waits until the queue is shutdown. The `Effect` returned by this method will
  */
-export declare const awaitShutdown: <A>(self: Queue<A>) => Effect.Effect<never, never, void>;
+export declare const awaitShutdown: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, void>;
 /**
@@ -381,3 +381,3 @@ * Interrupts any fibers that are suspended on `offer` or `take`. Future calls
  */
-export declare const shutdown: <A>(self: Queue<A>) => Effect.Effect<never, never, void>;
+export declare const shutdown: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, void>;
 /**
@@ -384,0 +384,0 @@ * Places one value in the queue.

Scheduler.d.ts

 /**
  * @since 1.0.0
  */
-import type { FiberRef } from "@effect/io/FiberRef";
 /**
  * @since 1.0.0
+ * @category models
  */
-export interface Task {
-    (): void;
-}
+export type Task = () => void;
 /**
  * @since 1.0.0
+ * @category models
  */
@@ -17,10 +16,2 @@ export interface Scheduler {
 }
-/**
- * @since 1.0.0
- */
-export declare const defaultScheduler: Scheduler;
-/**
- * @since 1.0.0
- */
-export declare const currentScheduler: FiberRef<Scheduler>;
 //# sourceMappingURL=Scheduler.d.ts.map

Scheduler.js

@@ -6,17 +6,2 @@ "use strict";
 });
-exports.defaultScheduler = exports.currentScheduler = void 0;
-var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));
-var internal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));
-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); }
-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; }
-/**
- * @since 1.0.0
- */
-const defaultScheduler = internal.defaultScheduler;
-/**
- * @since 1.0.0
- */
-exports.defaultScheduler = defaultScheduler;
-const currentScheduler = core.currentScheduler;
-exports.currentScheduler = currentScheduler;
 //# sourceMappingURL=Scheduler.js.map

src/FiberRef.ts

@@ -9,2 +9,3 @@ /**
 import * as fiberRuntime from "@effect/io/internal/fiberRuntime"
+import type * as Scheduler from "@effect/io/Scheduler"
 import * as logger from "@effect/io/internal/logger"
@@ -339,2 +340,8 @@ import type * as Logger from "@effect/io/Logger"
  */
+export const currentScheduler: FiberRef<Scheduler.Scheduler> = core.currentScheduler
+
+/**
+ * @since 1.0.0
+ * @category fiberRefs
+ */
 export const currentSupervisor: FiberRef<Supervisor.Supervisor<any>> = fiberRuntime.currentSupervisor
@@ -341,0 +348,0 @@

src/internal/queue.ts

@@ -378,3 +378,3 @@ import { getCallTrace } from "@effect/io/Debug"
 /** @internal */
-export const capacity = <A>(self: Queue.Queue<A>): number => {
+export const capacity = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): number => {
   return self.capacity()
@@ -384,3 +384,3 @@ }
 /** @internal */
-export const size = <A>(self: Queue.Queue<A>): Effect.Effect<never, never, number> => {
+export const size = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): Effect.Effect<never, never, number> => {
   const trace = getCallTrace()
@@ -391,3 +391,3 @@ return self.size().traced(trace)
 /** @internal */
-export const isFull = <A>(self: Queue.Queue<A>): Effect.Effect<never, never, boolean> => {
+export const isFull = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): Effect.Effect<never, never, boolean> => {
   const trace = getCallTrace()
@@ -398,3 +398,3 @@ return self.isFull().traced(trace)
 /** @internal */
-export const isEmpty = <A>(self: Queue.Queue<A>): Effect.Effect<never, never, boolean> => {
+export const isEmpty = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): Effect.Effect<never, never, boolean> => {
   const trace = getCallTrace()
@@ -405,3 +405,3 @@ return self.isEmpty().traced(trace)
 /** @internal */
-export const isShutdown = <A>(self: Queue.Queue<A>): Effect.Effect<never, never, boolean> => {
+export const isShutdown = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): Effect.Effect<never, never, boolean> => {
   const trace = getCallTrace()
@@ -412,3 +412,3 @@ return self.isShutdown().traced(trace)
 /** @internal */
-export const awaitShutdown = <A>(self: Queue.Queue<A>): Effect.Effect<never, never, void> => {
+export const awaitShutdown = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): Effect.Effect<never, never, void> => {
   const trace = getCallTrace()
@@ -419,3 +419,3 @@ return self.awaitShutdown().traced(trace)
 /** @internal */
-export const shutdown = <A>(self: Queue.Queue<A>): Effect.Effect<never, never, void> => {
+export const shutdown = <A>(self: Queue.Dequeue<A> | Queue.Enqueue<A>): Effect.Effect<never, never, void> => {
   const trace = getCallTrace()
@@ -422,0 +422,0 @@ return self.shutdown().traced(trace)

src/internal/runtime.ts

@@ -16,3 +16,4 @@ import type * as Cause from "@effect/io/Cause"
 import * as runtimeFlags from "@effect/io/internal/runtimeFlags"
-import * as Scheduler from "@effect/io/internal/scheduler"
+import * as Scheduler from "@effect/io/Scheduler"
+import * as _scheduler from "@effect/io/internal/scheduler"
 import * as _supervisor from "@effect/io/internal/supervisor"
@@ -110,3 +111,3 @@ import type * as Runtime from "@effect/io/Runtime"
   ): Exit.Exit<E, A> => {
-    const scheduler = new Scheduler.SyncScheduler()
+    const scheduler = new _scheduler.SyncScheduler()
 
@@ -113,0 +114,0 @@ const fiberRuntime = this.unsafeFork(effect, scheduler)

src/internal/scheduler.ts

@@ -1,13 +0,7 @@
-/** @internal */
-export type Task = () => void
+import type * as Scheduler from "@effect/io/Scheduler"
 
 /** @internal */
-export interface Scheduler {
-  scheduleTask(task: Task): void
-}
-
-/** @internal */
 export class HighPriorityScheduler {
   running = false
-  tasks: Array<Task> = []
+  tasks: Array<Scheduler.Task> = []
   readonly promise = Promise.resolve(void 0)
@@ -36,3 +30,3 @@
 
-  scheduleTask(task: Task) {
+  scheduleTask(task: Scheduler.Task) {
     this.tasks.push(task)
@@ -47,10 +41,10 @@ if (!this.running) {
 /** @internal */
-export const defaultScheduler: Scheduler = new HighPriorityScheduler()
+export const defaultScheduler: Scheduler.Scheduler = new HighPriorityScheduler()
 
 /** @internal */
 export class SyncScheduler {
-  tasks: Array<Task> = []
+  tasks: Array<Scheduler.Task> = []
   deferred = false
 
-  scheduleTask(task: Task) {
+  scheduleTask(task: Scheduler.Task) {
     if (this.deferred) {
@@ -57,0 +51,0 @@ defaultScheduler.scheduleTask(task)

src/Queue.ts

@@ -378,3 +378,3 @@ /**
  */
-export const capacity: <A>(self: Queue<A>) => number = internal.capacity
+export const capacity: <A>(self: Dequeue<A> | Enqueue<A>) => number = internal.capacity
 
@@ -390,3 +390,3 @@ /**
  */
-export const size: <A>(self: Queue<A>) => Effect.Effect<never, never, number> = internal.size
+export const size: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, number> = internal.size
 
@@ -400,3 +400,3 @@ /**
  */
-export const isEmpty: <A>(self: Queue<A>) => Effect.Effect<never, never, boolean> = internal.isEmpty
+export const isEmpty: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, boolean> = internal.isEmpty
 
@@ -411,3 +411,3 @@ /**
  */
-export const isFull: <A>(self: Queue<A>) => Effect.Effect<never, never, boolean> = internal.isFull
+export const isFull: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, boolean> = internal.isFull
 
@@ -421,3 +421,4 @@ /**
  */
-export const isShutdown: <A>(self: Queue<A>) => Effect.Effect<never, never, boolean> = internal.isShutdown
+export const isShutdown: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, boolean> =
+  internal.isShutdown
 
@@ -433,3 +434,4 @@ /**
  */
-export const awaitShutdown: <A>(self: Queue<A>) => Effect.Effect<never, never, void> = internal.awaitShutdown
+export const awaitShutdown: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, void> =
+  internal.awaitShutdown
 
@@ -444,3 +446,3 @@ /**
  */
-export const shutdown: <A>(self: Queue<A>) => Effect.Effect<never, never, void> = internal.shutdown
+export const shutdown: <A>(self: Dequeue<A> | Enqueue<A>) => Effect.Effect<never, never, void> = internal.shutdown
 
@@ -447,0 +449,0 @@ /**

src/Scheduler.ts

 /**
  * @since 1.0.0
  */
-import type { FiberRef } from "@effect/io/FiberRef"
-import * as core from "@effect/io/internal/core"
-import * as internal from "@effect/io/internal/scheduler"
 
 /**
  * @since 1.0.0
+ * @category models
  */
-export interface Task {
-  (): void
-}
+export type Task = () => void
 
 /**
  * @since 1.0.0
+ * @category models
  */
@@ -21,11 +18,1 @@ export interface Scheduler {
 }
-
-/**
- * @since 1.0.0
- */
-export const defaultScheduler: Scheduler = internal.defaultScheduler
-
-/**
- * @since 1.0.0
- */
-export const currentScheduler: FiberRef<Scheduler> = core.currentScheduler

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

5224484

decreased by-0.03%

Number of package files

877

decreased by-0.79%

Lines of code

104397

decreased by-0.05%

Dependency changes

• Updated@fp-ts/data@~0.0.26