Socket
Socket
Sign inDemoInstall

@effect/io

Package Overview
Dependencies
Maintainers
3
Versions
183
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@effect/io - npm Package Compare versions

Comparing version 0.0.2 to 0.0.3

73

Cause.d.ts

@@ -24,9 +24,12 @@ /**

*/
import type { FiberId } from "@effect/io/Fiber/Id";
import * as internal from "@effect/io/internal/cause";
import type * as FiberId from "@effect/io/Fiber/Id";
import type { Continuation } from "@effect/io/internal/core";
import type { Stack } from "@effect/io/internal/stack";
import type { Chunk } from "@fp-ts/data/Chunk";
import type { Equal } from "@fp-ts/data/Equal";
import type { Option } from "@fp-ts/data/Option";
import type * as Chunk from "@fp-ts/data/Chunk";
import type * as Either from "@fp-ts/data/Either";
import type * as Equal from "@fp-ts/data/Equal";
import type * as HashSet from "@fp-ts/data/HashSet";
import type * as List from "@fp-ts/data/List";
import type * as Option from "@fp-ts/data/Option";
import type { Predicate } from "@fp-ts/data/Predicate";
/**

@@ -145,3 +148,3 @@ * @since 1.0.0

readonly stack: Stack<Continuation> | undefined;
readonly execution: Chunk<string> | undefined;
readonly execution: Chunk.Chunk<string> | undefined;
}

@@ -154,3 +157,3 @@ /**

readonly [SpanAnnotationTypeId]: SpanAnnotationTypeId;
readonly currentSpanURI: Option<string>;
readonly currentSpanURI: Option.Option<string>;
}

@@ -169,3 +172,3 @@ }

readonly dieCase: (context: C, defect: unknown) => Z;
readonly interruptCase: (context: C, fiberId: FiberId) => Z;
readonly interruptCase: (context: C, fiberId: FiberId.FiberId) => Z;
readonly annotatedCase: (context: C, value: Z, annotation: unknown) => Z;

@@ -252,3 +255,3 @@ readonly sequentialCase: (context: C, left: Z, right: Z) => Z;

*/
export interface Empty extends Cause.Variance<never>, Equal {
export interface Empty extends Cause.Variance<never>, Equal.Equal {
readonly _tag: "Empty";

@@ -263,3 +266,3 @@ }

*/
export interface Fail<E> extends Cause.Variance<E>, Equal {
export interface Fail<E> extends Cause.Variance<E>, Equal.Equal {
readonly _tag: "Fail";

@@ -276,3 +279,3 @@ readonly error: E;

*/
export interface Die extends Cause.Variance<never>, Equal {
export interface Die extends Cause.Variance<never>, Equal.Equal {
readonly _tag: "Die";

@@ -288,5 +291,5 @@ readonly defect: unknown;

*/
export interface Interrupt extends Cause.Variance<never>, Equal {
export interface Interrupt extends Cause.Variance<never>, Equal.Equal {
readonly _tag: "Interrupt";
readonly fiberId: FiberId;
readonly fiberId: FiberId.FiberId;
}

@@ -302,3 +305,3 @@ /**

*/
export interface Annotated<E> extends Cause.Variance<E>, Equal {
export interface Annotated<E> extends Cause.Variance<E>, Equal.Equal {
readonly _tag: "Annotated";

@@ -321,3 +324,3 @@ readonly cause: Cause<E>;

*/
export interface Parallel<E> extends Cause.Variance<E>, Equal {
export interface Parallel<E> extends Cause.Variance<E>, Equal.Equal {
readonly _tag: "Parallel";

@@ -339,3 +342,3 @@ readonly left: Cause<E>;

*/
export interface Sequential<E> extends Cause.Variance<E>, Equal {
export interface Sequential<E> extends Cause.Variance<E>, Equal.Equal {
readonly _tag: "Sequential";

@@ -372,3 +375,3 @@ readonly left: Cause<E>;

*/
export declare const interrupt: (fiberId: FiberId) => Cause<never>;
export declare const interrupt: (fiberId: FiberId.FiberId) => Cause<never>;
/**

@@ -512,3 +515,3 @@ * Constructs a new `Annotated` cause from the specified `annotation`.

*/
export declare const failures: <E>(self: Cause<E>) => import("@fp-ts/data/List").List<E>;
export declare const failures: <E>(self: Cause<E>) => List.List<E>;
/**

@@ -520,3 +523,3 @@ * Returns a `List` of all unrecoverable defects in the specified cause.

*/
export declare const defects: <E>(self: Cause<E>) => import("@fp-ts/data/List").List<unknown>;
export declare const defects: <E>(self: Cause<E>) => List.List<unknown>;
/**

@@ -529,3 +532,3 @@ * Returns a `HashSet` of `FiberId`s for all fibers that interrupted the fiber

*/
export declare const interruptors: <E>(self: Cause<E>) => import("@fp-ts/data/HashSet").HashSet<FiberId>;
export declare const interruptors: <E>(self: Cause<E>) => HashSet.HashSet<FiberId.FiberId>;
/**

@@ -538,3 +541,3 @@ * Returns the `E` associated with the first `Fail` in this `Cause`, if one

*/
export declare const failureOption: <E>(self: Cause<E>) => Option<E>;
export declare const failureOption: <E>(self: Cause<E>) => Option.Option<E>;
/**

@@ -548,3 +551,3 @@ * Returns the first checked error on the `Left` if available, if there are

*/
export declare const failureOrCause: <E>(self: Cause<E>) => import("@fp-ts/data/Either").Either<E, Cause<never>>;
export declare const failureOrCause: <E>(self: Cause<E>) => Either.Either<E, Cause<never>>;
/**

@@ -557,3 +560,3 @@ * Returns the defect associated with the first `Die` in this `Cause`, if one

*/
export declare const dieOption: <E>(self: Cause<E>) => Option<unknown>;
export declare const dieOption: <E>(self: Cause<E>) => Option.Option<unknown>;
/**

@@ -566,3 +569,3 @@ * Returns the `FiberId` associated with the first `Interrupt` in the specified

*/
export declare const interruptOption: <E>(self: Cause<E>) => Option<FiberId>;
export declare const interruptOption: <E>(self: Cause<E>) => Option.Option<FiberId.FiberId>;
/**

@@ -575,3 +578,3 @@ * Remove all `Fail` and `Interrupt` nodes from the specified cause, and return

*/
export declare const keepDefects: <E>(self: Cause<E>) => Option<Cause<never>>;
export declare const keepDefects: <E>(self: Cause<E>) => Option.Option<Cause<never>>;
/**

@@ -584,3 +587,3 @@ * Linearizes the specified cause into a `HashSet` of parallel causes where each

*/
export declare const linearize: <E>(self: Cause<E>) => import("@fp-ts/data/HashSet").HashSet<Cause<E>>;
export declare const linearize: <E>(self: Cause<E>) => HashSet.HashSet<Cause<E>>;
/**

@@ -602,3 +605,3 @@ * Remove all `Fail` and `Interrupt` nodes from the specified cause, and return

*/
export declare const stripSomeDefects: (pf: (defect: unknown) => Option<unknown>) => <E>(self: Cause<E>) => Option<Cause<E>>;
export declare const stripSomeDefects: (pf: (defect: unknown) => Option.Option<unknown>) => <E>(self: Cause<E>) => Option.Option<Cause<E>>;
/**

@@ -656,3 +659,3 @@ * @since 1.0.0

*/
export declare const find: <E, Z>(pf: (cause: Cause<E>) => Option<Z>) => (self: Cause<E>) => Option<Z>;
export declare const find: <E, Z>(pf: (cause: Cause<E>) => Option.Option<Z>) => (self: Cause<E>) => Option.Option<Z>;
/**

@@ -664,3 +667,3 @@ * Filters causes which match the provided predicate out of the specified cause.

*/
export declare const filter: <E>(predicate: import("@fp-ts/data/Predicate").Predicate<Cause<E>>) => (self: Cause<E>) => Cause<E>;
export declare const filter: <E>(predicate: Predicate<Cause<E>>) => (self: Cause<E>) => Cause<E>;
/**

@@ -672,3 +675,3 @@ * Folds the specified cause into a value of type `Z`.

*/
export declare const match: <Z, E>(emptyCase: Z, failCase: (error: E) => Z, dieCase: (defect: unknown) => Z, interruptCase: (fiberId: FiberId) => Z, annotatedCase: (value: Z, annotation: unknown) => Z, sequentialCase: (left: Z, right: Z) => Z, parallelCase: (left: Z, right: Z) => Z) => (self: Cause<E>) => Z;
export declare const match: <Z, E>(emptyCase: Z, failCase: (error: E) => Z, dieCase: (defect: unknown) => Z, interruptCase: (fiberId: FiberId.FiberId) => Z, annotatedCase: (value: Z, annotation: unknown) => Z, sequentialCase: (left: Z, right: Z) => Z, parallelCase: (left: Z, right: Z) => Z) => (self: Cause<E>) => Z;
/**

@@ -681,3 +684,3 @@ * Reduces the specified cause into a value of type `Z`, beginning with the

*/
export declare const reduce: <Z, E>(zero: Z, pf: (accumulator: Z, cause: Cause<E>) => Option<Z>) => (self: Cause<E>) => Z;
export declare const reduce: <Z, E>(zero: Z, pf: (accumulator: Z, cause: Cause<E>) => Option.Option<Z>) => (self: Cause<E>) => Z;
/**

@@ -697,3 +700,3 @@ * Reduces the specified cause into a value of type `Z` using a `Cause.Reducer`.

*/
export declare const InterruptedException: typeof internal.InterruptedException;
export declare const InterruptedException: (message?: string | undefined) => InterruptedException;
/**

@@ -714,3 +717,3 @@ * Returns `true` if the specified value is an `InterruptedException`, `false`

*/
export declare const IllegalArgumentException: typeof internal.IllegalArgumentException;
export declare const IllegalArgumentException: (message?: string | undefined) => IllegalArgumentException;
/**

@@ -731,3 +734,3 @@ * Returns `true` if the specified value is an `IllegalArgumentException`, `false`

*/
export declare const NoSuchElementException: typeof internal.NoSuchElementException;
export declare const NoSuchElementException: (message?: string | undefined) => NoSuchElementException;
/**

@@ -747,3 +750,3 @@ * Returns `true` if the specified value is an `IllegalArgumentException`, `false`

*/
export declare const RuntimeException: typeof internal.RuntimeException;
export declare const RuntimeException: (message?: string | undefined) => RuntimeException;
/**

@@ -750,0 +753,0 @@ * Returns `true` if the specified value is an `RuntimeException`, `false`

3

Clock.d.ts

@@ -63,2 +63,3 @@ /**

/**
* @macro traced
* @since 1.0.0

@@ -69,2 +70,3 @@ * @category constructors

/**
* @macro traced
* @since 1.0.0

@@ -75,2 +77,3 @@ * @category constructors

/**
* @macro traced
* @since 1.0.0

@@ -77,0 +80,0 @@ * @category constructors

3

Clock.js

@@ -23,2 +23,3 @@ "use strict";

/**
* @macro traced
* @since 1.0.0

@@ -30,2 +31,3 @@ * @category constructors

/**
* @macro traced
* @since 1.0.0

@@ -37,2 +39,3 @@ * @category constructors

/**
* @macro traced
* @since 1.0.0

@@ -39,0 +42,0 @@ * @category constructors

6

Debug.d.ts
/**
* @since 1.0.0
*/
import type { LogLevel } from "@effect/io/Logger/Level";
import type * as LogLevel from "@effect/io/Logger/Level";
/**

@@ -13,3 +13,3 @@ * @since 1.0.0

*/
logLevelOverride: LogLevel | undefined;
logLevelOverride: LogLevel.LogLevel | undefined;
/**

@@ -77,3 +77,3 @@ * When specified it will be used to collect call traces at runtime.

*/
export declare const withCallTrace: (trace: string) => <A>(x: A) => A;
export declare const withCallTrace: (trace: string) => <A>(value: A) => A;
/**

@@ -80,0 +80,0 @@ * @since 1.0.0

2

Debug.js

@@ -61,3 +61,3 @@ "use strict";

}
return undefined;
return void 0;
};

@@ -64,0 +64,0 @@ /**

6

DefaultServices.d.ts

@@ -5,3 +5,5 @@ /**

import type * as Clock from "@effect/io/Clock";
import type * as FiberRef from "@effect/io/FiberRef";
import type * as Random from "@effect/io/Random";
import type * as Context from "@fp-ts/data/Context";
/**

@@ -16,3 +18,3 @@ * @since 1.0.0

*/
export declare const liveServices: import("@fp-ts/data/Context").Context<DefaultServices>;
export declare const liveServices: Context.Context<DefaultServices>;
/**

@@ -22,3 +24,3 @@ * @since 1.0.0

*/
export declare const currentServices: import("./FiberRef").FiberRef<import("@fp-ts/data/Context").Context<DefaultServices>>;
export declare const currentServices: FiberRef.FiberRef<Context.Context<DefaultServices>>;
//# sourceMappingURL=DefaultServices.d.ts.map

42

Deferred.d.ts
/**
* @since 1.0.0
*/
import type * as Cause from "@effect/io/Cause";
import type * as Effect from "@effect/io/Effect";
import type * as Exit from "@effect/io/Exit";
import type * as FiberId from "@effect/io/Fiber/Id";
import type * as Option from "@fp-ts/data/Option";
/**

@@ -51,3 +55,3 @@ * @since 1.0.0

*/
export declare const make: <E, A>() => import("./Effect").Effect<never, never, Deferred<E, A>>;
export declare const make: <E, A>() => Effect.Effect<never, never, Deferred<E, A>>;
/**

@@ -60,3 +64,3 @@ * Creates a new `Deferred` from the specified `FiberId`.

*/
export declare const makeAs: <E, A>(fiberId: FiberId.FiberId) => import("./Effect").Effect<never, never, Deferred<E, A>>;
export declare const makeAs: <E, A>(fiberId: FiberId.FiberId) => Effect.Effect<never, never, Deferred<E, A>>;
/**

@@ -69,3 +73,3 @@ * Completes the `Deferred` with the specified value.

*/
export declare const succeed: <A>(value: A) => <E>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const succeed: <A>(value: A) => <E>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -78,3 +82,3 @@ * Completes the `Deferred` with the specified value.

*/
export declare const sync: <A>(evaluate: () => A) => <E>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const sync: <A>(evaluate: () => A) => <E>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -88,3 +92,3 @@ * Fails the `Deferred` with the specified error, which will be propagated to

*/
export declare const fail: <E>(error: E) => <A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const fail: <E>(error: E) => <A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -98,3 +102,3 @@ * Fails the `Deferred` with the specified error, which will be propagated to

*/
export declare const failSync: <E>(evaluate: () => E) => <A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const failSync: <E>(evaluate: () => E) => <A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -108,3 +112,3 @@ * Fails the `Deferred` with the specified `Cause`, which will be propagated to

*/
export declare const failCause: <E>(cause: import("./Cause").Cause<E>) => <A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const failCause: <E>(cause: Cause.Cause<E>) => <A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -118,3 +122,3 @@ * Fails the `Deferred` with the specified `Cause`, which will be propagated to

*/
export declare const failCauseSync: <E>(evaluate: () => import("./Cause").Cause<E>) => <A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const failCauseSync: <E>(evaluate: () => Cause.Cause<E>) => <A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -128,3 +132,3 @@ * Kills the `Deferred` with the specified defect, which will be propagated to

*/
export declare const die: (defect: unknown) => <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const die: (defect: unknown) => <E, A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -138,3 +142,3 @@ * Kills the `Deferred` with the specified defect, which will be propagated to

*/
export declare const dieSync: (evaluate: () => unknown) => <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const dieSync: (evaluate: () => unknown) => <E, A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -149,3 +153,3 @@ * Completes the `Deferred` with interruption. This will interrupt all fibers

*/
export declare const interrupt: <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const interrupt: <E, A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -159,3 +163,3 @@ * Completes the `Deferred` with interruption. This will interrupt all fibers

*/
export declare const interruptWith: (fiberId: FiberId.FiberId) => <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const interruptWith: (fiberId: FiberId.FiberId) => <E, A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -169,3 +173,3 @@ * Exits the `Deferred` with the specified `Exit` value, which will be

*/
export declare const done: <E, A>(exit: import("./Exit").Exit<E, A>) => (self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const done: <E, A>(exit: Exit.Exit<E, A>) => (self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -179,3 +183,3 @@ * Returns `true` if this `Deferred` has already been completed with a value or

*/
export declare const isDone: <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const isDone: <E, A>(self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -189,4 +193,4 @@ * Returns a `Some<Effect<R, E, A>>` from the `Deferred` if this `Deferred` has

*/
export declare const poll: <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, never, import("@fp-ts/data/Option").Option<import("./Effect").Effect<never, E, A>>>;
declare const _await: <E, A>(self: Deferred<E, A>) => import("./Effect").Effect<never, E, A>;
export declare const poll: <E, A>(self: Deferred<E, A>) => Effect.Effect<never, never, Option.Option<Effect.Effect<never, E, A>>>;
declare const _await: <E, A>(self: Deferred<E, A>) => Effect.Effect<never, E, A>;
export {

@@ -213,3 +217,3 @@ /**

*/
export declare const complete: <E, A>(effect: import("./Effect").Effect<never, E, A>) => (self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const complete: <E, A>(effect: Effect.Effect<never, E, A>) => (self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -223,3 +227,3 @@ * Completes the deferred with the result of the specified effect. If the

*/
export declare const completeWith: <E, A>(effect: import("./Effect").Effect<never, E, A>) => (self: Deferred<E, A>) => import("./Effect").Effect<never, never, boolean>;
export declare const completeWith: <E, A>(effect: Effect.Effect<never, E, A>) => (self: Deferred<E, A>) => Effect.Effect<never, never, boolean>;
/**

@@ -239,3 +243,3 @@ * Unsafely creates a new `Deferred` from the specified `FiberId`.

*/
export declare const unsafeDone: <E, A>(effect: import("./Effect").Effect<never, E, A>) => (self: Deferred<E, A>) => void;
export declare const unsafeDone: <E, A>(effect: Effect.Effect<never, E, A>) => (self: Deferred<E, A>) => void;
//# sourceMappingURL=Deferred.d.ts.map

19

Exit.d.ts

@@ -6,2 +6,7 @@ /**

import type * as Effect from "@effect/io/Effect";
import type * as FiberId from "@effect/io/Fiber/Id";
import type * as Either from "@fp-ts/data/Either";
import type * as List from "@fp-ts/data/List";
import type * as Option from "@fp-ts/data/Option";
import type { Predicate } from "@fp-ts/data/Predicate";
/**

@@ -95,3 +100,3 @@ * An `Exit<E, A>` describes the result of a executing an `Effect` workflow.

*/
export declare const interrupt: (fiberId: import("./Fiber/Id").FiberId) => Exit<never, never>;
export declare const interrupt: (fiberId: FiberId.FiberId) => Exit<never, never>;
/**

@@ -106,3 +111,3 @@ * Collects all of the specified exit values into a `Some<Exit<E, List<A>>>`. If

*/
export declare const collectAll: <E, A>(exits: Iterable<Exit<E, A>>) => import("@fp-ts/data/Option").Option<Exit<E, import("@fp-ts/data/List").List<A>>>;
export declare const collectAll: <E, A>(exits: Iterable<Exit<E, A>>) => Option.Option<Exit<E, List.List<A>>>;
/**

@@ -117,3 +122,3 @@ * Collects all of the specified exit values into a `Some<Exit<E, List<A>>>`. If

*/
export declare const collectAllPar: <E, A>(exits: Iterable<Exit<E, A>>) => import("@fp-ts/data/Option").Option<Exit<E, import("@fp-ts/data/List").List<A>>>;
export declare const collectAllPar: <E, A>(exits: Iterable<Exit<E, A>>) => Option.Option<Exit<E, List.List<A>>>;
/**

@@ -132,3 +137,3 @@ * Represents an `Exit` which succeeds with `undefined`.

*/
export declare const fromEither: <E, A>(either: import("@fp-ts/data/Either").Either<E, A>) => Exit<E, A>;
export declare const fromEither: <E, A>(either: Either.Either<E, A>) => Exit<E, A>;
/**

@@ -140,3 +145,3 @@ * Converts an `Option<A>` into an `Exit<void, A>`.

*/
export declare const fromOption: <A>(option: import("@fp-ts/data/Option").Option<A>) => Exit<void, A>;
export declare const fromOption: <A>(option: Option.Option<A>) => Exit<void, A>;
/**

@@ -157,3 +162,3 @@ * Returns `true` if the specified exit is a `Failure` **and** the `Cause` of

*/
export declare const causeOption: <E, A>(self: Exit<E, A>) => import("@fp-ts/data/Option").Option<Cause.Cause<E>>;
export declare const causeOption: <E, A>(self: Exit<E, A>) => Option.Option<Cause.Cause<E>>;
/**

@@ -175,3 +180,3 @@ * Returns the `A` if specified exit is a `Success`, otherwise returns the

*/
export declare const exists: <A>(predicate: import("@fp-ts/data/Predicate").Predicate<A>) => <E>(self: Exit<E, A>) => boolean;
export declare const exists: <A>(predicate: Predicate<A>) => <E>(self: Exit<E, A>) => boolean;
/**

@@ -178,0 +183,0 @@ * Maps the `Success` value of the specified exit to the provided constant

18

Fiber.d.ts
/**
* @since 1.0.0
*/
import type * as Cause from "@effect/io/Cause";
import type * as Effect from "@effect/io/Effect";

@@ -11,5 +12,6 @@ import type * as Exit from "@effect/io/Exit";

import type * as FiberRefs from "@effect/io/FiberRefs";
import * as internal from "@effect/io/internal/fiber";
import * as fiberRuntime from "@effect/io/internal/fiberRuntime";
import type * as Scope from "@effect/io/Scope";
import type * as order from "@fp-ts/core/typeclass/Order";
import type * as Chunk from "@fp-ts/data/Chunk";
import type * as Either from "@fp-ts/data/Either";
import type * as HashSet from "@fp-ts/data/HashSet";

@@ -200,3 +202,3 @@ import type * as Option from "@fp-ts/data/Option";

*/
export declare const Order: import("@fp-ts/core/typeclass/Order").Order<RuntimeFiber<unknown, unknown>>;
export declare const Order: order.Order<RuntimeFiber<unknown, unknown>>;
/**

@@ -259,3 +261,3 @@ * Returns `true` if the specified value is a `Fiber`, `false` otherwise.

*/
export declare const collectAll: typeof fiberRuntime.fiberCollectAll;
export declare const collectAll: <E, A>(fibers: Iterable<Fiber<E, A>>) => Fiber<E, Chunk.Chunk<A>>;
/**

@@ -294,3 +296,3 @@ * A fiber that is done with the specified `Exit` value.

*/
export declare const failCause: <E>(cause: import("./Cause").Cause<E>) => Fiber<E, never>;
export declare const failCause: <E>(cause: Cause.Cause<E>) => Fiber<E, never>;
/**

@@ -428,3 +430,3 @@ * Lifts an `Effect` into a `Fiber`.

*/
export declare const match: typeof internal.match;
export declare const match: <E, A, Z>(onFiber: (_: Fiber<E, A>) => Z, onRuntimeFiber: (_: RuntimeFiber<E, A>) => Z) => (self: Fiber<E, A>) => Z;
/**

@@ -454,3 +456,3 @@ * A fiber that never fails or succeeds.

*/
export declare const orElseEither: <E2, A2>(that: Fiber<E2, A2>) => <E, A>(self: Fiber<E, A>) => Fiber<E2 | E, import("@fp-ts/data/Either").Either<A, A2>>;
export declare const orElseEither: <E2, A2>(that: Fiber<E2, A2>) => <E, A>(self: Fiber<E, A>) => Fiber<E2 | E, Either.Either<A, A2>>;
/**

@@ -489,3 +491,3 @@ * Tentatively observes the fiber, but returns immediately if it is not

*/
export declare const scoped: <E, A>(self: Fiber<E, A>) => Effect.Effect<import("./Scope").Scope, never, Fiber<E, A>>;
export declare const scoped: <E, A>(self: Fiber<E, A>) => Effect.Effect<Scope.Scope, never, Fiber<E, A>>;
/**

@@ -492,0 +494,0 @@ * Returns the `FiberStatus` of a `RuntimeFiber`.

71

Fiber/Runtime/Flags.d.ts

@@ -5,2 +5,3 @@ /**

import type * as RuntimeFlagsPatch from "@effect/io/Fiber/Runtime/Flags/Patch";
import type * as Layer from "@effect/io/Layer";
import type * as Differ from "@fp-ts/data/Differ";

@@ -147,2 +148,37 @@ /**

/**
* @since 1.0.0
* @category environment
*/
export declare const disableCooperativeYielding: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const disableCurrentFiber: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const disableFiberRoots: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const disableInterruption: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const disableOpSupervision: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const disableRuntimeMetrics: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const disableWindDown: () => Layer.Layer<never, never, never>;
/**
* Enables the specified `RuntimeFlag`.

@@ -162,2 +198,37 @@ *

/**
* @since 1.0.0
* @category environment
*/
export declare const enableCooperativeYielding: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const enableCurrentFiber: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const enableFiberRoots: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const enableInterruption: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const enableOpSupervision: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const enableRuntimeMetrics: () => Layer.Layer<never, never, never>;
/**
* @since 1.0.0
* @category environment
*/
export declare const enableWindDown: () => Layer.Layer<never, never, never>;
/**
* Returns `true` if the `FiberRoots` `RuntimeFlag` is enabled, `false`

@@ -164,0 +235,0 @@ * otherwise.

91

Fiber/Runtime/Flags.js

@@ -6,3 +6,4 @@ "use strict";

});
exports.windDown = exports.toSet = exports.runtimeMetrics = exports.render = exports.patch = exports.opSupervision = exports.none = exports.make = exports.isEnabled = exports.isDisabled = exports.interruption = exports.interruptible = exports.fiberRoots = exports.enableAll = exports.enable = exports.disableAll = exports.disable = exports.differ = exports.diff = exports.currentFiber = exports.cooperativeYielding = exports.WindDown = exports.RuntimeMetrics = exports.OpSupervision = exports.None = exports.Interruption = exports.FiberRoots = exports.CurrentFiber = exports.CooperativeYielding = void 0;
exports.windDown = exports.toSet = exports.runtimeMetrics = exports.render = exports.patch = exports.opSupervision = exports.none = exports.make = exports.isEnabled = exports.isDisabled = exports.interruption = exports.interruptible = exports.fiberRoots = exports.enableWindDown = exports.enableRuntimeMetrics = exports.enableOpSupervision = exports.enableInterruption = exports.enableFiberRoots = exports.enableCurrentFiber = exports.enableCooperativeYielding = exports.enableAll = exports.enable = exports.disableWindDown = exports.disableRuntimeMetrics = exports.disableOpSupervision = exports.disableInterruption = exports.disableFiberRoots = exports.disableCurrentFiber = exports.disableCooperativeYielding = exports.disableAll = exports.disable = exports.differ = exports.diff = exports.currentFiber = exports.cooperativeYielding = exports.WindDown = exports.RuntimeMetrics = exports.OpSupervision = exports.None = exports.Interruption = exports.FiberRoots = exports.CurrentFiber = exports.CooperativeYielding = void 0;
var circular = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/layer/circular"));
var internal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));

@@ -143,2 +144,44 @@ 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); }

/**
* @since 1.0.0
* @category environment
*/
exports.disableAll = disableAll;
const disableCooperativeYielding = circular.disableCooperativeYielding;
/**
* @since 1.0.0
* @category environment
*/
exports.disableCooperativeYielding = disableCooperativeYielding;
const disableCurrentFiber = circular.disableCurrentFiber;
/**
* @since 1.0.0
* @category environment
*/
exports.disableCurrentFiber = disableCurrentFiber;
const disableFiberRoots = circular.disableFiberRoots;
/**
* @since 1.0.0
* @category environment
*/
exports.disableFiberRoots = disableFiberRoots;
const disableInterruption = circular.disableInterruption;
/**
* @since 1.0.0
* @category environment
*/
exports.disableInterruption = disableInterruption;
const disableOpSupervision = circular.disableOpSupervision;
/**
* @since 1.0.0
* @category environment
*/
exports.disableOpSupervision = disableOpSupervision;
const disableRuntimeMetrics = circular.disableRuntimeMetrics;
/**
* @since 1.0.0
* @category environment
*/
exports.disableRuntimeMetrics = disableRuntimeMetrics;
const disableWindDown = circular.disableWindDown;
/**
* Enables the specified `RuntimeFlag`.

@@ -149,3 +192,3 @@ *

*/
exports.disableAll = disableAll;
exports.disableWindDown = disableWindDown;
const enable = internal.enable;

@@ -161,2 +204,44 @@ /**

/**
* @since 1.0.0
* @category environment
*/
exports.enableAll = enableAll;
const enableCooperativeYielding = circular.enableCooperativeYielding;
/**
* @since 1.0.0
* @category environment
*/
exports.enableCooperativeYielding = enableCooperativeYielding;
const enableCurrentFiber = circular.enableCurrentFiber;
/**
* @since 1.0.0
* @category environment
*/
exports.enableCurrentFiber = enableCurrentFiber;
const enableFiberRoots = circular.enableFiberRoots;
/**
* @since 1.0.0
* @category environment
*/
exports.enableFiberRoots = enableFiberRoots;
const enableInterruption = circular.enableInterruption;
/**
* @since 1.0.0
* @category environment
*/
exports.enableInterruption = enableInterruption;
const enableOpSupervision = circular.enableOpSupervision;
/**
* @since 1.0.0
* @category environment
*/
exports.enableOpSupervision = enableOpSupervision;
const enableRuntimeMetrics = circular.enableRuntimeMetrics;
/**
* @since 1.0.0
* @category environment
*/
exports.enableRuntimeMetrics = enableRuntimeMetrics;
const enableWindDown = circular.enableWindDown;
/**
* Returns `true` if the `FiberRoots` `RuntimeFlag` is enabled, `false`

@@ -168,3 +253,3 @@ * otherwise.

*/
exports.enableAll = enableAll;
exports.enableWindDown = enableWindDown;
const fiberRoots = internal.fiberRoots;

@@ -171,0 +256,0 @@ /**

94

FiberRef.d.ts
/**
* @since 1.0.0
*/
import type * as Cause from "@effect/io/Cause";
import type * as Effect from "@effect/io/Effect";
import type * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
import type * as Logger from "@effect/io/Logger";
import type * as LogLevel from "@effect/io/Logger/Level";
import type * as LogSpan from "@effect/io/Logger/Span";
import type * as Scope from "@effect/io/Scope";
import type * as Supervisor from "@effect/io/Supervisor";
import type * as Context from "@fp-ts/data/Context";
import type * as Differ from "@fp-ts/data/Differ";
import type * as HashSet from "@fp-ts/data/HashSet";
import type * as List from "@fp-ts/data/List";
import type * as Option from "@fp-ts/data/Option";
/**
* @since 1.0.0
* @category symbols

@@ -31,3 +47,3 @@ */

*/
export declare const make: <A>(initial: A, fork?: (a: A) => A, join?: (left: A, right: A) => A) => import("./Effect").Effect<import("./Scope").Scope, never, FiberRef<A>>;
export declare const make: <A>(initial: A, fork?: (a: A) => A, join?: (left: A, right: A) => A) => Effect.Effect<Scope.Scope, never, FiberRef<A>>;
/**

@@ -38,3 +54,3 @@ * @macro traced

*/
export declare const makeWith: <Value>(ref: () => FiberRef<Value>) => import("./Effect").Effect<import("./Scope").Scope, never, FiberRef<Value>>;
export declare const makeWith: <Value>(ref: () => FiberRef<Value>) => Effect.Effect<Scope.Scope, never, FiberRef<Value>>;
/**

@@ -45,3 +61,3 @@ * @macro traced

*/
export declare const makeEnvironment: <A>(initial: import("@fp-ts/data/Context").Context<A>) => import("./Effect").Effect<import("./Scope").Scope, never, FiberRef<import("@fp-ts/data/Context").Context<A>>>;
export declare const makeEnvironment: <A>(initial: Context.Context<A>) => Effect.Effect<Scope.Scope, never, FiberRef<Context.Context<A>>>;
/**

@@ -52,3 +68,3 @@ * @macro traced

*/
export declare const makeRuntimeFlags: (initial: import("./Fiber/Runtime/Flags").RuntimeFlags) => import("./Effect").Effect<import("./Scope").Scope, never, FiberRef<import("./Fiber/Runtime/Flags").RuntimeFlags>>;
export declare const makeRuntimeFlags: (initial: RuntimeFlags.RuntimeFlags) => Effect.Effect<Scope.Scope, never, FiberRef<RuntimeFlags.RuntimeFlags>>;
/**

@@ -63,3 +79,3 @@ * @since 1.0.0

*/
export declare const unsafeMakeHashSet: <A>(initial: import("@fp-ts/data/HashSet").HashSet<A>) => FiberRef<import("@fp-ts/data/HashSet").HashSet<A>>;
export declare const unsafeMakeHashSet: <A>(initial: HashSet.HashSet<A>) => FiberRef<HashSet.HashSet<A>>;
/**

@@ -69,3 +85,3 @@ * @since 1.0.0

*/
export declare const unsafeMakeEnvironment: <A>(initial: import("@fp-ts/data/Context").Context<A>) => FiberRef<import("@fp-ts/data/Context").Context<A>>;
export declare const unsafeMakeEnvironment: <A>(initial: Context.Context<A>) => FiberRef<Context.Context<A>>;
/**

@@ -75,3 +91,3 @@ * @since 1.0.0

*/
export declare const unsafeMakeSupervisor: (initial: import("./Supervisor").Supervisor<any>) => FiberRef<import("./Supervisor").Supervisor<any>>;
export declare const unsafeMakeSupervisor: (initial: Supervisor.Supervisor<any>) => FiberRef<Supervisor.Supervisor<any>>;
/**

@@ -81,3 +97,3 @@ * @since 1.0.0

*/
export declare const unsafeMakePatch: <Value, Patch>(initial: Value, differ: import("@fp-ts/data/Differ").Differ<Value, Patch>, fork: Patch, join?: (oldV: Value, newV: Value) => Value) => FiberRef<Value>;
export declare const unsafeMakePatch: <Value, Patch>(initial: Value, differ: Differ.Differ<Value, Patch>, fork: Patch, join?: (oldV: Value, newV: Value) => Value) => FiberRef<Value>;
/**

@@ -88,3 +104,3 @@ * @macro traced

*/
export declare const get: <A>(self: FiberRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const get: <A>(self: FiberRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -95,3 +111,3 @@ * @macro traced

*/
export declare const getAndSet: <A>(value: A) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const getAndSet: <A>(value: A) => (self: FiberRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -102,3 +118,3 @@ * @macro traced

*/
export declare const getAndUpdate: <A>(f: (a: A) => A) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const getAndUpdate: <A>(f: (a: A) => A) => (self: FiberRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -109,3 +125,3 @@ * @macro traced

*/
export declare const getAndUpdateSome: <A>(pf: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const getAndUpdateSome: <A>(pf: (a: A) => Option.Option<A>) => (self: FiberRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -116,3 +132,3 @@ * @macro traced

*/
export declare const getWith: <R, E, A, B>(f: (a: A) => import("./Effect").Effect<R, E, B>) => (self: FiberRef<A>) => import("./Effect").Effect<R, E, B>;
export declare const getWith: <R, E, A, B>(f: (a: A) => Effect.Effect<R, E, B>) => (self: FiberRef<A>) => Effect.Effect<R, E, B>;
/**

@@ -123,4 +139,4 @@ * @macro traced

*/
export declare const set: <A>(value: A) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, void>;
declare const _delete: <A>(self: FiberRef<A>) => import("./Effect").Effect<never, never, void>;
export declare const set: <A>(value: A) => (self: FiberRef<A>) => Effect.Effect<never, never, void>;
declare const _delete: <A>(self: FiberRef<A>) => Effect.Effect<never, never, void>;
export {

@@ -138,3 +154,3 @@ /**

*/
export declare const reset: <A>(self: FiberRef<A>) => import("./Effect").Effect<never, never, void>;
export declare const reset: <A>(self: FiberRef<A>) => Effect.Effect<never, never, void>;
/**

@@ -145,3 +161,3 @@ * @macro traced

*/
export declare const modify: <A, B>(f: (a: A) => readonly [B, A]) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, B>;
export declare const modify: <A, B>(f: (a: A) => readonly [B, A]) => (self: FiberRef<A>) => Effect.Effect<never, never, B>;
/**

@@ -152,3 +168,3 @@ * @macro traced

*/
export declare const modifySome: <B, A>(def: B, f: (a: A) => import("@fp-ts/data/Option").Option<readonly [B, A]>) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, B>;
export declare const modifySome: <B, A>(def: B, f: (a: A) => Option.Option<readonly [B, A]>) => (self: FiberRef<A>) => Effect.Effect<never, never, B>;
/**

@@ -159,3 +175,3 @@ * @macro traced

*/
export declare const update: <A>(f: (a: A) => A) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, void>;
export declare const update: <A>(f: (a: A) => A) => (self: FiberRef<A>) => Effect.Effect<never, never, void>;
/**

@@ -166,3 +182,3 @@ * @macro traced

*/
export declare const updateSome: <A>(pf: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, void>;
export declare const updateSome: <A>(pf: (a: A) => Option.Option<A>) => (self: FiberRef<A>) => Effect.Effect<never, never, void>;
/**

@@ -173,3 +189,3 @@ * @macro traced

*/
export declare const updateAndGet: <A>(f: (a: A) => A) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const updateAndGet: <A>(f: (a: A) => A) => (self: FiberRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -180,3 +196,3 @@ * @macro traced

*/
export declare const updateSomeAndGet: <A>(pf: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: FiberRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const updateSomeAndGet: <A>(pf: (a: A) => Option.Option<A>) => (self: FiberRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -187,3 +203,3 @@ * @macro traced

*/
export declare const locally: <A>(value: A) => (self: FiberRef<A>) => <R, E, B>(use: import("./Effect").Effect<R, E, B>) => import("./Effect").Effect<R, E, B>;
export declare const locally: <A>(value: A) => (self: FiberRef<A>) => <R, E, B>(use: Effect.Effect<R, E, B>) => Effect.Effect<R, E, B>;
/**

@@ -194,3 +210,3 @@ * @macro traced

*/
export declare const locallyWith: <A>(f: (a: A) => A) => (self: FiberRef<A>) => <R, E, B>(use: import("./Effect").Effect<R, E, B>) => import("./Effect").Effect<R, E, B>;
export declare const locallyWith: <A>(f: (a: A) => A) => (self: FiberRef<A>) => <R, E, B>(use: Effect.Effect<R, E, B>) => Effect.Effect<R, E, B>;
/**

@@ -201,3 +217,3 @@ * @macro traced

*/
export declare const locallyScoped: <A>(value: A) => (self: FiberRef<A>) => import("./Effect").Effect<import("./Scope").Scope, never, void>;
export declare const locallyScoped: <A>(value: A) => (self: FiberRef<A>) => Effect.Effect<Scope.Scope, never, void>;
/**

@@ -208,3 +224,3 @@ * @macro traced

*/
export declare const locallyScopedWith: <A>(value: A) => (self: FiberRef<A>) => import("./Effect").Effect<import("./Scope").Scope, never, void>;
export declare const locallyScopedWith: <A>(value: A) => (self: FiberRef<A>) => Effect.Effect<Scope.Scope, never, void>;
/**

@@ -215,3 +231,3 @@ * @macro traced

*/
export declare const currentEnvironment: FiberRef<import("@fp-ts/data/Context").Context<never>>;
export declare const currentEnvironment: FiberRef<Context.Context<never>>;
/**

@@ -227,3 +243,3 @@ * @macro traced

*/
export declare const currentLoggers: FiberRef<import("@fp-ts/data/HashSet").HashSet<import("./Logger").Logger<string, any>>>;
export declare const currentLoggers: FiberRef<HashSet.HashSet<Logger.Logger<string, any>>>;
/**

@@ -233,3 +249,3 @@ * @since 1.0.0

*/
export declare const currentLogLevel: FiberRef<import("./Logger/Level").LogLevel>;
export declare const currentLogLevel: FiberRef<LogLevel.LogLevel>;
/**

@@ -239,3 +255,3 @@ * @since 1.0.0

*/
export declare const currentLogSpan: FiberRef<import("@fp-ts/data/List").List<import("./Logger/Span").LogSpan>>;
export declare const currentLogSpan: FiberRef<List.List<LogSpan.LogSpan>>;
/**

@@ -245,3 +261,3 @@ * @since 1.0.0

*/
export declare const currentRuntimeFlags: FiberRef<import("./Fiber/Runtime/Flags").RuntimeFlags>;
export declare const currentRuntimeFlags: FiberRef<RuntimeFlags.RuntimeFlags>;
/**

@@ -251,3 +267,3 @@ * @since 1.0.0

*/
export declare const currentScheduler: FiberRef<import("./internal/scheduler").Scheduler>;
export declare const currentParallelism: FiberRef<Option.Option<number>>;
/**

@@ -257,3 +273,3 @@ * @since 1.0.0

*/
export declare const currentParallelism: FiberRef<import("@fp-ts/data/Option").Option<number>>;
export declare const currentSupervisor: FiberRef<Supervisor.Supervisor<any>>;
/**

@@ -263,13 +279,3 @@ * @since 1.0.0

*/
export declare const currentSupervisor: FiberRef<import("./Supervisor").Supervisor<any>>;
/**
* @since 1.0.0
* @category fiberRefs
*/
export declare const forkScopeOverride: FiberRef<import("@fp-ts/data/Option").Option<import("./internal/fiberScope").FiberScope>>;
/**
* @since 1.0.0
* @category fiberRefs
*/
export declare const interruptedCause: FiberRef<import("./Cause").Cause<never>>;
export declare const interruptedCause: FiberRef<Cause.Cause<never>>;
//# sourceMappingURL=FiberRef.d.ts.map

18

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.forkScopeOverride = exports.delete = exports.currentSupervisor = exports.currentScheduler = 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.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"));

@@ -15,6 +15,2 @@ var fiberRuntime = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberRuntime"));

* @since 1.0.0
*/
/**
* @since 1.0.0
* @category symbols

@@ -245,8 +241,2 @@ */

exports.currentRuntimeFlags = currentRuntimeFlags;
const currentScheduler = core.currentScheduler;
/**
* @since 1.0.0
* @category fiberRefs
*/
exports.currentScheduler = currentScheduler;
const currentParallelism = core.currentParallelism;

@@ -264,10 +254,4 @@ /**

exports.currentSupervisor = currentSupervisor;
const forkScopeOverride = core.forkScopeOverride;
/**
* @since 1.0.0
* @category fiberRefs
*/
exports.forkScopeOverride = forkScopeOverride;
const interruptedCause = core.interruptedCause;
exports.interruptedCause = interruptedCause;
//# sourceMappingURL=FiberRef.js.map

72

FiberRefs.d.ts
/**
* @since 1.0.0
*/
import type * as Effect from "@effect/io/Effect";
import type * as FiberId from "@effect/io/Fiber/Id";
import type * as FiberRef from "@effect/io/FiberRef";
import * as internal from "@effect/io/internal/fiberRefs";
import type * as HashSet from "@fp-ts/data/HashSet";
import type * as List from "@fp-ts/data/List";
import type * as Option from "@fp-ts/data/Option";
/**
* Note: it will not copy the provided Map, make sure to provide a fresh one.
*
* @since 1.0.0
* @category unsafe
*/
export declare const unsafeMake: typeof internal.unsafeMake;
/**
* @since 1.0.0
* @category symbols

@@ -38,12 +34,19 @@ */

}
declare const delete_: <A>(fiberRef: FiberRef.FiberRef<A>) => (self: FiberRefs) => FiberRefs;
export {
/**
* Joins this collection of fiber refs to the specified collection, as the
* specified fiber id. This will perform diffing and merging to ensure
* preservation of maximum information from both child and parent refs.
* Deletes the specified `FiberRef` from the `FibterRefs`.
*
* @since 1.0.0
* @category utilities
* @category mutations
*/
export declare const joinAs: (fiberId: FiberId.Runtime, that: FiberRefs) => (self: FiberRefs) => FiberRefs;
delete_ as delete };
/**
* Returns a set of each `FiberRef` in this collection.
*
* @since 1.0.0
* @category getters
*/
export declare const fiberRefs: (self: FiberRefs) => HashSet.HashSet<FiberRef.FiberRef<any>>;
/**
* Forks this collection of fiber refs as the specified child fiber id. This

@@ -54,23 +57,25 @@ * will potentially modify the value of the fiber refs, as determined by the

* @since 1.0.0
* @category utilities
* @category mutations
*/
export declare const forkAs: (childId: FiberId.Runtime) => (self: FiberRefs) => internal.FiberRefsImpl;
/**
* Returns a set of each `FiberRef` in this collection.
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or `None` otherwise.
*
* @since 1.0.0
* @category utilities
* @category getters
*/
export declare const fiberRefs: (self: FiberRefs) => import("@fp-ts/data/HashSet").HashSet<FiberRef.FiberRef<any>>;
export declare const get: <A>(fiberRef: FiberRef.FiberRef<A>) => (self: FiberRefs) => Option.Option<A>;
/**
* Set each ref to either its value or its default.
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or the `initial` value of the `FiberRef` otherwise.
*
* @since 1.0.0
* @category mutations
* @category getters
*/
export declare const setAll: (self: FiberRefs) => import("./Effect").Effect<never, never, void>;
declare const delete_: <A>(fiberRef: FiberRef.FiberRef<A>) => (self: FiberRefs) => FiberRefs;
export {
export declare const getOrDefault: <A>(fiberRef: FiberRef.FiberRef<A>) => (self: FiberRefs) => A;
/**
* Deletes the specified `FiberRef` from the `FibterRefs`.
* Joins this collection of fiber refs to the specified collection, as the
* specified fiber id. This will perform diffing and merging to ensure
* preservation of maximum information from both child and parent refs.
*

@@ -80,26 +85,25 @@ * @since 1.0.0

*/
delete_ as delete };
export declare const joinAs: (fiberId: FiberId.Runtime, that: FiberRefs) => (self: FiberRefs) => FiberRefs;
/**
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or `None` otherwise.
* Set each ref to either its value or its default.
*
* @macro traced
* @since 1.0.0
* @category utilities
* @category mutations
*/
export declare const get: <A>(fiberRef: FiberRef.FiberRef<A>) => (self: FiberRefs) => import("@fp-ts/data/Option").Option<A>;
export declare const setAll: (self: FiberRefs) => Effect.Effect<never, never, void>;
/**
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or the `initial` value of the `FiberRef` otherwise.
* Updates the value of the specified `FiberRef` using the provided `FiberId`
*
* @since 1.0.0
* @category utilities
* @category mutations
*/
export declare const getOrDefault: <A>(fiberRef: FiberRef.FiberRef<A>) => (self: FiberRefs) => A;
export declare const updatedAs: <A>(fiberId: FiberId.Runtime, fiberRef: FiberRef.FiberRef<A>, value: A) => (self: FiberRefs) => FiberRefs;
/**
* Updates the value of the specified `FiberRef` using the provided `FiberId`
* Note: it will not copy the provided Map, make sure to provide a fresh one.
*
* @since 1.0.0
* @category mutations
* @category unsafe
*/
export declare const updatedAs: <A>(fiberId: FiberId.Runtime, fiberRef: FiberRef.FiberRef<A>, value: A) => (self: FiberRefs) => FiberRefs;
export declare const unsafeMake: (fiberRefLocals: Map<FiberRef.FiberRef<any>, List.Cons<readonly [FiberId.Runtime, any]>>) => FiberRefs;
//# sourceMappingURL=FiberRefs.d.ts.map

73

FiberRefs.js

@@ -11,24 +11,16 @@ "use strict";

/**
* Note: it will not copy the provided Map, make sure to provide a fresh one.
*
* @since 1.0.0
* @category unsafe
*/
const unsafeMake = internal.unsafeMake;
/**
* @since 1.0.0
* @category symbols
*/
exports.unsafeMake = unsafeMake;
const FiberRefsSym = internal.FiberRefsSym;
exports.FiberRefsSym = FiberRefsSym;
const delete_ = internal.delete;
exports.delete = delete_;
/**
* Joins this collection of fiber refs to the specified collection, as the
* specified fiber id. This will perform diffing and merging to ensure
* preservation of maximum information from both child and parent refs.
* Returns a set of each `FiberRef` in this collection.
*
* @since 1.0.0
* @category utilities
* @category getters
*/
exports.FiberRefsSym = FiberRefsSym;
const joinAs = internal.joinAs;
const fiberRefs = internal.fiberRefs;
/**

@@ -40,42 +32,43 @@ * Forks this collection of fiber refs as the specified child fiber id. This

* @since 1.0.0
* @category utilities
* @category mutations
*/
exports.joinAs = joinAs;
exports.fiberRefs = fiberRefs;
const forkAs = internal.forkAs;
/**
* Returns a set of each `FiberRef` in this collection.
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or `None` otherwise.
*
* @since 1.0.0
* @category utilities
* @category getters
*/
exports.forkAs = forkAs;
const fiberRefs = internal.fiberRefs;
const get = internal.get;
/**
* Set each ref to either its value or its default.
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or the `initial` value of the `FiberRef` otherwise.
*
* @since 1.0.0
* @category mutations
* @category getters
*/
exports.fiberRefs = fiberRefs;
const setAll = internal.setAll;
exports.setAll = setAll;
const delete_ = internal.delete;
exports.delete = delete_;
exports.get = get;
const getOrDefault = internal.getOrDefault;
/**
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or `None` otherwise.
* Joins this collection of fiber refs to the specified collection, as the
* specified fiber id. This will perform diffing and merging to ensure
* preservation of maximum information from both child and parent refs.
*
* @since 1.0.0
* @category utilities
* @category mutations
*/
const get = internal.get;
exports.getOrDefault = getOrDefault;
const joinAs = internal.joinAs;
/**
* Gets the value of the specified `FiberRef` in this collection of `FiberRef`
* values if it exists or the `initial` value of the `FiberRef` otherwise.
* Set each ref to either its value or its default.
*
* @macro traced
* @since 1.0.0
* @category utilities
* @category mutations
*/
exports.get = get;
const getOrDefault = internal.getOrDefault;
exports.joinAs = joinAs;
const setAll = internal.setAll;
/**

@@ -87,5 +80,13 @@ * Updates the value of the specified `FiberRef` using the provided `FiberId`

*/
exports.getOrDefault = getOrDefault;
exports.setAll = setAll;
const updatedAs = internal.updatedAs;
/**
* Note: it will not copy the provided Map, make sure to provide a fresh one.
*
* @since 1.0.0
* @category unsafe
*/
exports.updatedAs = updatedAs;
const unsafeMake = internal.unsafeMake;
exports.unsafeMake = unsafeMake;
//# sourceMappingURL=FiberRefs.js.map

6

FiberRefs/Patch.d.ts
/**
* @since 1.0.0
*/
import type * as FiberId from "@effect/io/Fiber/Id";
import type * as FiberRef from "@effect/io/FiberRef";
import type * as FiberRefs from "@effect/io/FiberRefs";
import * as internal from "@effect/io/internal/fiberRefs/patch";

@@ -70,3 +72,3 @@ /**

*/
export declare const diff: (oldValue: import("../FiberRefs").FiberRefs, newValue: import("../FiberRefs").FiberRefs) => FiberRefsPatch;
export declare const diff: (oldValue: FiberRefs.FiberRefs, newValue: FiberRefs.FiberRefs) => FiberRefsPatch;
/**

@@ -88,3 +90,3 @@ * Combines this patch and the specified patch to create a new patch that

*/
export declare const patch: (fiberId: import("../Fiber/Id").Runtime, oldValue: import("../FiberRefs").FiberRefs) => (self: FiberRefsPatch) => import("../FiberRefs").FiberRefs;
export declare const patch: (fiberId: FiberId.Runtime, oldValue: FiberRefs.FiberRefs) => (self: FiberRefsPatch) => FiberRefs.FiberRefs;
//# sourceMappingURL=Patch.d.ts.map

79

internal/cause.js

@@ -25,3 +25,3 @@ "use strict";

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; }
var _a, _b, _c, _d, _e, _f, _g;
var _a, _b;
// -----------------------------------------------------------------------------

@@ -445,5 +445,5 @@ // Models

const fibers = HashSet.reduce("", (acc, id) => `${acc}, ${id}`)(HashSet.flatMap(fiberId => HashSet.map(n => `#${n}`)(FiberId.ids(fiberId)))(interruptors(self)));
return new InterruptedException(`Interrupted by fibers: ${fibers}`);
return InterruptedException(`Interrupted by fibers: ${fibers}`);
}
return Option.match(() => new InterruptedException(), _Function.identity)(List.head(defects(self)));
return Option.match(() => InterruptedException(), _Function.identity)(List.head(defects(self)));
}

@@ -838,11 +838,8 @@ case "Some":

exports.RuntimeExceptionTypeId = RuntimeExceptionTypeId;
class RuntimeException {
constructor(message) {
this.message = message;
this[_a] = RuntimeExceptionTypeId;
}
}
const RuntimeException = message => ({
[RuntimeExceptionTypeId]: RuntimeExceptionTypeId,
message
});
/** @internal */
exports.RuntimeException = RuntimeException;
_a = RuntimeExceptionTypeId;
/** @internal */
const isRuntimeException = u => {

@@ -856,11 +853,8 @@ return typeof u === "object" && u != null && RuntimeExceptionTypeId in u;

exports.InterruptedExceptionTypeId = InterruptedExceptionTypeId;
class InterruptedException {
constructor(message) {
this.message = message;
this[_b] = InterruptedExceptionTypeId;
}
}
const InterruptedException = message => ({
[InterruptedExceptionTypeId]: InterruptedExceptionTypeId,
message
});
/** @internal */
exports.InterruptedException = InterruptedException;
_b = InterruptedExceptionTypeId;
/** @internal */
const isInterruptedException = u => {

@@ -874,11 +868,8 @@ return typeof u === "object" && u != null && InterruptedExceptionTypeId in u;

exports.IllegalArgumentExceptionTypeId = IllegalArgumentExceptionTypeId;
class IllegalArgumentException {
constructor(message) {
this.message = message;
this[_c] = IllegalArgumentExceptionTypeId;
}
}
const IllegalArgumentException = message => ({
[IllegalArgumentExceptionTypeId]: IllegalArgumentExceptionTypeId,
message
});
/** @internal */
exports.IllegalArgumentException = IllegalArgumentException;
_c = IllegalArgumentExceptionTypeId;
/** @internal */
const isIllegalArgumentException = u => {

@@ -892,11 +883,8 @@ return typeof u === "object" && u != null && IllegalArgumentExceptionTypeId in u;

exports.NoSuchElementExceptionTypeId = NoSuchElementExceptionTypeId;
class NoSuchElementException {
constructor(message) {
this.message = message;
this[_d] = NoSuchElementExceptionTypeId;
}
}
const NoSuchElementException = message => ({
[NoSuchElementExceptionTypeId]: NoSuchElementExceptionTypeId,
message
});
/** @internal */
exports.NoSuchElementException = NoSuchElementException;
_d = NoSuchElementExceptionTypeId;
/** @internal */
const isNoSuchElementException = u => {

@@ -910,11 +898,8 @@ return typeof u === "object" && u != null && NoSuchElementExceptionTypeId in u;

exports.InvalidHubCapacityExceptionTypeId = InvalidHubCapacityExceptionTypeId;
class InvalidHubCapacityException {
constructor(message) {
this.message = message;
this[_e] = InvalidHubCapacityExceptionTypeId;
}
}
const InvalidHubCapacityException = message => ({
[InvalidHubCapacityExceptionTypeId]: InvalidHubCapacityExceptionTypeId,
message
});
/** @internal */
exports.InvalidHubCapacityException = InvalidHubCapacityException;
_e = InvalidHubCapacityExceptionTypeId;
/** @internal */
const isInvalidCapacityError = u => {

@@ -935,7 +920,7 @@ return typeof u === "object" && u != null && InvalidHubCapacityExceptionTypeId in u;

this.execution = execution;
this[_f] = StackAnnotationTypeId;
this[_a] = StackAnnotationTypeId;
}
}
exports.StackAnnotation = StackAnnotation;
_f = StackAnnotationTypeId;
_a = StackAnnotationTypeId;
/** @internal */

@@ -956,7 +941,7 @@ const isStackAnnotation = u => {

this.currentSpanURI = currentSpanURI;
this[_g] = SpanAnnotationTypeId;
this[_b] = SpanAnnotationTypeId;
}
}
exports.SpanAnnotation = SpanAnnotation;
_g = SpanAnnotationTypeId;
_b = SpanAnnotationTypeId;
/** @internal */

@@ -963,0 +948,0 @@ const isSpanAnnotation = u => {

112

internal/core.js

@@ -7,10 +7,10 @@ "use strict";

exports.fiberRefSet = exports.fiberRefReset = exports.fiberRefModifySome = exports.fiberRefModify = exports.fiberRefLocallyWith = exports.fiberRefLocally = exports.fiberRefGetWith = exports.fiberRefGetAndUpdateSome = exports.fiberRefGetAndSet = exports.fiberRefGet = exports.fiberRefDelete = exports.fiberIdWith = exports.fiberId = exports.failSync = exports.failCauseSync = exports.failCause = exports.fail = exports.exitZipWith = exports.exitZipRight = exports.exitZipParRight = exports.exitZipParLeft = exports.exitZipPar = exports.exitZipLeft = exports.exitZip = exports.exitUnit = exports.exitUnannotate = exports.exitSucceed = exports.exitMatchEffect = exports.exitMatch = exports.exitMapErrorCause = exports.exitMapError = exports.exitMapBoth = exports.exitMap = exports.exitIsSuccess = exports.exitIsInterrupted = exports.exitIsFailure = exports.exitIsExit = exports.exitInterrupt = exports.exitGetOrElse = exports.exitFromOption = exports.exitFromEither = exports.exitForEachEffect = exports.exitFlatten = exports.exitFlatMapEffect = exports.exitFlatMap = exports.exitFailCause = exports.exitFail = exports.exitExists = exports.exitDie = exports.exitCollectAllPar = exports.exitCollectAll = exports.exitCauseOption = exports.exitAsUnit = exports.exitAs = exports.exit = exports.environmentWithEffect = exports.environment = exports.either = exports.done = exports.dieSync = exports.die = exports.deferredUnsafeMake = exports.deferredUnsafeDone = exports.deferredSync = exports.deferredSucceed = exports.deferredPoll = exports.deferredMakeAs = exports.deferredMake = exports.deferredIsDone = exports.deferredInterruptWith = exports.deferredInterrupt = exports.deferredFailSync = exports.deferredFailCauseSync = exports.deferredFailCause = exports.deferredFail = exports.deferredDone = exports.deferredDieSync = exports.deferredDie = exports.deferredCompleteWith = exports.deferredComplete = exports.deferredAwait = exports.currentScheduler = exports.currentParallelism = exports.currentLogSpan = exports.currentLogLevel = exports.currentLogAnnotations = exports.currentEnvironment = exports.checkInterruptible = exports.catchAllCause = exports.asyncInterrupt = exports.async = exports.asUnit = exports.as = exports.acquireUseRelease = exports.ScopeTypeId = exports.RevertFlags = exports.FiberRefTypeId = exports.EffectTypeId = exports.EffectErrorTypeId = exports.CloseableScopeTypeId = void 0;
exports.zipWith = exports.zipRight = exports.zipLeft = exports.zip = exports.yieldNow = exports.withRuntimeFlags = exports.withParallelismUnbounded = exports.withParallelism = exports.withFiberRuntime = exports.whileLoop = exports.whenEffect = exports.updateRuntimeFlags = exports.unit = exports.uninterruptibleMask = exports.uninterruptible = exports.transplant = exports.traced = exports.tap = exports.sync = exports.suspendSucceed = exports.succeed = exports.serviceWithEffect = exports.serviceWith = exports.service = exports.scopeFork = exports.scopeClose = exports.scopeAddFinalizerExit = exports.scopeAddFinalizer = exports.releaseMapReplace = exports.releaseMapRemove = exports.releaseMapRelease = exports.releaseMapMake = exports.releaseMapGet = exports.releaseMapAddIfOpen = exports.releaseMapAdd = exports.provideSomeEnvironment = exports.provideEnvironment = exports.proto = exports.partitionMap = exports.onInterrupt = exports.onExit = exports.onError = exports.never = exports.map = exports.makeEffectError = exports.isEffectError = exports.isEffect = exports.intoDeferred = exports.interruptibleMask = exports.interruptible = exports.interruptedCause = exports.interruptWithFiber = exports.interruptFiber = exports.interruptAs = exports.interrupt = exports.ifEffect = exports.forkScopeOverride = exports.forEachDiscard = exports.forEach = exports.foldEffect = exports.foldCauseEffect = exports.foldCause = exports.flip = exports.flatten = exports.flatMap = exports.fiberRefgetAndUpdate = exports.fiberRefUpdateSomeAndGet = exports.fiberRefUpdateSome = exports.fiberRefUpdateAndGet = exports.fiberRefUpdate = exports.fiberRefUnsafeMakeRuntimeFlags = exports.fiberRefUnsafeMakePatch = exports.fiberRefUnsafeMakeHashSet = exports.fiberRefUnsafeMakeEnvironment = exports.fiberRefUnsafeMake = void 0;
exports.zipWith = exports.zipRight = exports.zipLeft = exports.zip = exports.yieldNow = exports.withRuntimeFlags = exports.withParallelismUnbounded = exports.withParallelism = exports.withFiberRuntime = exports.whileLoop = exports.whenEffect = exports.updateRuntimeFlags = exports.unit = exports.uninterruptibleMask = exports.uninterruptible = exports.transplant = exports.traced = exports.tap = exports.sync = exports.suspendSucceed = exports.succeed = exports.serviceWithEffect = exports.serviceWith = exports.service = exports.scopeFork = exports.scopeClose = exports.scopeAddFinalizerExit = exports.scopeAddFinalizer = exports.runtimeFlags = exports.releaseMapReplace = exports.releaseMapRemove = exports.releaseMapRelease = exports.releaseMapMake = exports.releaseMapGet = exports.releaseMapAddIfOpen = exports.releaseMapAdd = exports.provideSomeEnvironment = exports.provideEnvironment = exports.proto = exports.partitionMap = exports.onInterrupt = exports.onExit = exports.onError = exports.never = exports.map = exports.makeEffectError = exports.logLevelWarning = exports.logLevelTrace = exports.logLevelNone = exports.logLevelInfo = exports.logLevelFatal = exports.logLevelError = exports.logLevelDebug = exports.logLevelAll = exports.isEffectError = exports.isEffect = exports.intoDeferred = exports.interruptibleMask = exports.interruptible = exports.interruptedCause = exports.interruptWithFiber = exports.interruptWith = exports.interruptFiber = exports.interrupt = exports.ifEffect = exports.forkScopeOverride = exports.forEachDiscard = exports.forEach = exports.foldEffect = exports.foldCauseEffect = exports.foldCause = exports.flip = exports.flatten = exports.flatMap = exports.fiberRefgetAndUpdate = exports.fiberRefUpdateSomeAndGet = exports.fiberRefUpdateSome = exports.fiberRefUpdateAndGet = exports.fiberRefUpdate = exports.fiberRefUnsafeMakeRuntimeFlags = exports.fiberRefUnsafeMakePatch = exports.fiberRefUnsafeMakeHashSet = exports.fiberRefUnsafeMakeEnvironment = exports.fiberRefUnsafeMake = void 0;
var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
var _Debug = /*#__PURE__*/require("@effect/io/Debug");
var FiberId = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Id"));
var RuntimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Runtime/Flags"));
var RuntimeFlagsPatch = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Runtime/Flags/Patch"));
var deferred = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/deferred"));
var OpCodes = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/opCodes/effect"));
var _runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
var Scheduler = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));

@@ -169,3 +169,3 @@ var SingleShotGen = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/singleShotGen"));

const trace = (0, _Debug.getCallTrace)();
return withFiberRuntime((_, status) => f(RuntimeFlags.interruption(status.runtimeFlags))).traced(trace);
return withFiberRuntime((_, status) => f(_runtimeFlags.interruption(status.runtimeFlags))).traced(trace);
};

@@ -356,7 +356,7 @@ /** @internal */

const trace = (0, _Debug.getCallTrace)();
return flatMap(fiberId => interruptAs(fiberId))(fiberId()).traced(trace);
return flatMap(fiberId => interruptWith(fiberId))(fiberId()).traced(trace);
};
/** @internal */
exports.interrupt = interrupt;
const interruptAs = fiberId => {
const interruptWith = fiberId => {
const trace = (0, _Debug.getCallTrace)();

@@ -366,3 +366,3 @@ return failCause(Cause.interrupt(fiberId)).traced(trace);

/** @internal */
exports.interruptAs = interruptAs;
exports.interruptWith = interruptWith;
const interruptible = self => {

@@ -372,3 +372,3 @@ const trace = (0, _Debug.getCallTrace)();

effect.op = OpCodes.OP_UPDATE_RUNTIME_FLAGS;
effect.update = RuntimeFlagsPatch.enable(RuntimeFlags.Interruption);
effect.update = RuntimeFlagsPatch.enable(_runtimeFlags.Interruption);
effect.scope = () => self;

@@ -384,4 +384,4 @@ effect.trace = trace;

effect.op = OpCodes.OP_UPDATE_RUNTIME_FLAGS;
effect.update = RuntimeFlagsPatch.enable(RuntimeFlags.Interruption);
effect.scope = oldFlags => RuntimeFlags.interruption(oldFlags) ? f(interruptible) : f(uninterruptible);
effect.update = RuntimeFlagsPatch.enable(_runtimeFlags.Interruption);
effect.scope = oldFlags => _runtimeFlags.interruption(oldFlags) ? f(interruptible) : f(uninterruptible);
effect.trace = trace;

@@ -480,2 +480,8 @@ return effect;

exports.provideSomeEnvironment = provideSomeEnvironment;
const runtimeFlags = () => {
const trace = (0, _Debug.getCallTrace)();
return withFiberRuntime((_, status) => succeed(status.runtimeFlags)).traced(trace);
};
/** @internal */
exports.runtimeFlags = runtimeFlags;
const service = tag => {

@@ -554,3 +560,3 @@ const trace = (0, _Debug.getCallTrace)();

effect.op = OpCodes.OP_UPDATE_RUNTIME_FLAGS;
effect.update = RuntimeFlagsPatch.disable(RuntimeFlags.Interruption);
effect.update = RuntimeFlagsPatch.disable(_runtimeFlags.Interruption);
effect.scope = () => self;

@@ -566,5 +572,5 @@ effect.trace = trace;

effect.op = OpCodes.OP_UPDATE_RUNTIME_FLAGS;
effect.update = RuntimeFlagsPatch.disable(RuntimeFlags.Interruption);
effect.update = RuntimeFlagsPatch.disable(_runtimeFlags.Interruption);
effect.scope = oldFlags => {
return RuntimeFlags.interruption(oldFlags) ? f(interruptible) : f(uninterruptible);
return _runtimeFlags.interruption(oldFlags) ? f(interruptible) : f(uninterruptible);
};

@@ -715,6 +721,73 @@ effect.trace = trace;

// -----------------------------------------------------------------------------
// LogLevel
// -----------------------------------------------------------------------------
/** @internal */
exports.interruptWithFiber = interruptWithFiber;
const logLevelAll = {
_tag: "All",
syslog: 0,
label: "ALL",
ordinal: Number.MIN_SAFE_INTEGER
};
/** @internal */
exports.logLevelAll = logLevelAll;
const logLevelFatal = {
_tag: "Fatal",
syslog: 2,
label: "FATAL",
ordinal: 50000
};
/** @internal */
exports.logLevelFatal = logLevelFatal;
const logLevelError = {
_tag: "Error",
syslog: 3,
label: "ERROR",
ordinal: 40000
};
/** @internal */
exports.logLevelError = logLevelError;
const logLevelWarning = {
_tag: "Warning",
syslog: 4,
label: "WARN",
ordinal: 30000
};
/** @internal */
exports.logLevelWarning = logLevelWarning;
const logLevelInfo = {
_tag: "Info",
syslog: 6,
label: "INFO",
ordinal: 20000
};
/** @internal */
exports.logLevelInfo = logLevelInfo;
const logLevelDebug = {
_tag: "Debug",
syslog: 7,
label: "DEBUG",
ordinal: 10000
};
/** @internal */
exports.logLevelDebug = logLevelDebug;
const logLevelTrace = {
_tag: "Trace",
syslog: 7,
label: "TRACE",
ordinal: 0
};
/** @internal */
exports.logLevelTrace = logLevelTrace;
const logLevelNone = {
_tag: "None",
syslog: 7,
label: "OFF",
ordinal: Number.MAX_SAFE_INTEGER
};
// -----------------------------------------------------------------------------
// FiberRef
// -----------------------------------------------------------------------------
/** @internal */
exports.interruptWithFiber = interruptWithFiber;
exports.logLevelNone = logLevelNone;
const FiberRefSymbolKey = "@effect/io/FiberRef";

@@ -895,3 +968,3 @@ /** @internal */

const fiberRefUnsafeMakeRuntimeFlags = initial => {
return fiberRefUnsafeMakePatch(initial, RuntimeFlags.differ(), RuntimeFlagsPatch.empty);
return fiberRefUnsafeMakePatch(initial, _runtimeFlags.differ(), RuntimeFlagsPatch.empty);
};

@@ -906,8 +979,3 @@ /** @internal */

exports.currentLogAnnotations = currentLogAnnotations;
const currentLogLevel = /*#__PURE__*/fiberRefUnsafeMake({
_tag: "Info",
syslog: 6,
label: "INFO",
ordinal: 20000
});
const currentLogLevel = /*#__PURE__*/fiberRefUnsafeMake(logLevelInfo);
/** @internal */

@@ -1603,3 +1671,3 @@ exports.currentLogLevel = currentLogLevel;

const trace = (0, _Debug.getCallTrace)();
return flatMap(fiberId => deferredCompleteWith(interruptAs(fiberId))(self))(fiberId()).traced(trace);
return flatMap(fiberId => deferredCompleteWith(interruptWith(fiberId))(self))(fiberId()).traced(trace);
};

@@ -1611,3 +1679,3 @@ /** @internal */

return self => {
return deferredCompleteWith(interruptAs(fiberId))(self).traced(trace);
return deferredCompleteWith(interruptWith(fiberId))(self).traced(trace);
};

@@ -1614,0 +1682,0 @@ };

8

internal/effect/circular.js

@@ -23,3 +23,3 @@ "use strict";

var TRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/stm/ref"));
var Supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Supervisor"));
var supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/supervisor"));
var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Either"));

@@ -108,3 +108,3 @@ var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));

return self => {
return core.flatMap(supervisor => ensuring(core.flatMap(children)(supervisor.value()))(supervised(supervisor)(self)))(Supervisor.track()).traced(trace);
return core.flatMap(supervisor => ensuring(core.flatMap(children)(supervisor.value()))(supervised(supervisor)(self)))(supervisor.track()).traced(trace);
};

@@ -437,3 +437,3 @@ };

if (n < 0) {
throw new Cause.IllegalArgumentException(`Unexpected negative value ${n} passed to Semaphore.acquireN`);
throw Cause.IllegalArgumentException(`Unexpected negative value ${n} passed to Semaphore.acquireN`);
}

@@ -454,3 +454,3 @@ const value = TRef.unsafeGet(journal)(self.permits);

if (n < 0) {
throw new Cause.IllegalArgumentException(`Unexpected negative value ${n} passed to Semaphore.releaseN`);
throw Cause.IllegalArgumentException(`Unexpected negative value ${n} passed to Semaphore.releaseN`);
}

@@ -457,0 +457,0 @@ const current = TRef.unsafeGet(journal)(self.permits);

4

internal/fiber.js

@@ -13,6 +13,6 @@ "use strict";

var FiberId = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Id"));
var RuntimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Runtime/Flags"));
var FiberStatus = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Status"));
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));
var fiberScope = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberScope"));
var runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
var order = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/core/typeclass/Order"));

@@ -338,3 +338,3 @@ var Chunk = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Chunk"));

}
const isInterruptible = RuntimeFlags.interruptible(status.runtimeFlags) ? "interruptible" : "uninterruptible";
const isInterruptible = runtimeFlags.interruptible(status.runtimeFlags) ? "interruptible" : "uninterruptible";
return `Suspended(${isInterruptible})`;

@@ -341,0 +341,0 @@ };

6

internal/fiberRefs.js

@@ -9,2 +9,3 @@ "use strict";

exports.updatedAs = void 0;
var _Debug = /*#__PURE__*/require("@effect/io/Debug");
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

@@ -124,3 +125,6 @@ var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));

exports.fiberRefs = fiberRefs;
const setAll = self => core.forEachDiscard(fiberRef => core.fiberRefSet(getOrDefault(fiberRef)(self))(fiberRef))(fiberRefs(self));
const setAll = self => {
const trace = (0, _Debug.getCallTrace)();
return core.forEachDiscard(fiberRef => core.fiberRefSet(getOrDefault(fiberRef)(self))(fiberRef))(fiberRefs(self)).traced(trace);
};
exports.setAll = setAll;

@@ -127,0 +131,0 @@ const delete_ = fiberRef => self => {

2

internal/fiberRuntime.d.ts
import type * as Effect from "@effect/io/Effect";
import * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
import type * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
import type * as FiberRef from "@effect/io/FiberRef";

@@ -4,0 +4,0 @@ import type * as Scope from "@effect/io/Scope";

2

internal/fiberScope.d.ts
import * as FiberId from "@effect/io/Fiber/Id";
import * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
import type * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
import type * as FiberRuntime from "@effect/io/internal/fiberRuntime";

@@ -4,0 +4,0 @@ export type FiberScopeTypeId = typeof FiberScopeTypeId;

4

internal/fiberScope.js

@@ -8,4 +8,4 @@ "use strict";

var FiberId = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Id"));
var RuntimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Runtime/Flags"));
var FiberMessage = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberMessage"));
var _runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
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); }

@@ -26,3 +26,3 @@ 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; }

add(runtimeFlags, child) {
if (RuntimeFlags.isEnabled(RuntimeFlags.FiberRoots)(runtimeFlags)) {
if (_runtimeFlags.isEnabled(_runtimeFlags.FiberRoots)(runtimeFlags)) {
_roots.add(child);

@@ -29,0 +29,0 @@ child.unsafeAddObserver(() => {

2

internal/hub.js

@@ -876,3 +876,3 @@ "use strict";

if (capacity <= 0) {
throw new cause.InvalidHubCapacityException(`Cannot construct Hub with capacity of ${capacity}`);
throw cause.InvalidHubCapacityException(`Cannot construct Hub with capacity of ${capacity}`);
}

@@ -879,0 +879,0 @@ };

91

internal/layer/circular.js

@@ -6,3 +6,3 @@ "use strict";

});
exports.loggerLayer = exports.consoleLoggerLayer = void 0;
exports.removeDefaultLoggers = exports.enableWindDown = exports.enableRuntimeMetrics = exports.enableOpSupervision = exports.enableInterruption = exports.enableFiberRoots = exports.enableCurrentFiber = exports.enableCooperativeYielding = exports.disableWindDown = exports.disableRuntimeMetrics = exports.disableOpSupervision = exports.disableInterruption = exports.disableFiberRoots = exports.disableCurrentFiber = exports.disableCooperativeYielding = exports.consoleLoggerLayer = exports.addSupervisor = exports.addLogger = void 0;
var _Debug = /*#__PURE__*/require("@effect/io/Debug");

@@ -12,2 +12,5 @@ var fiberRuntime = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberRuntime"));

var _logger = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/logger"));
var runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
var runtimeFlagsPatch = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlagsPatch"));
var _supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/supervisor"));
var LogLevel = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Logger/Level"));

@@ -22,10 +25,90 @@ var _Function = /*#__PURE__*/require("@fp-ts/data/Function");

const newMin = _Debug.runtimeDebug.logLevelOverride ? _Debug.runtimeDebug.logLevelOverride : minLevel;
return loggerLayer(_logger.map(_Function.constVoid)(_logger.filterLogLevel(LogLevel.greaterThanEqual(newMin))(_logger.consoleLogger())));
return addLogger(_logger.map(_Function.constVoid)(_logger.filterLogLevel(LogLevel.greaterThanEqual(newMin))(_logger.consoleLogger())));
};
/** @internal */
exports.consoleLoggerLayer = consoleLoggerLayer;
const loggerLayer = logger => {
const addLogger = logger => {
return layer.scopedDiscard(fiberRuntime.fiberRefLocallyScopedWith(HashSet.add(logger))(_logger.currentLoggers));
};
exports.loggerLayer = loggerLayer;
/** @internal */
exports.addLogger = addLogger;
const removeDefaultLoggers = () => {
return layer.scopedDiscard(fiberRuntime.fiberRefLocallyScopedWith(HashSet.remove(_logger.defaultLogger))(_logger.currentLoggers));
};
/** @internal */
exports.removeDefaultLoggers = removeDefaultLoggers;
const addSupervisor = supervisor => {
return layer.scopedDiscard(fiberRuntime.fiberRefLocallyScopedWith(current => new _supervisor.Zip(current, supervisor))(fiberRuntime.currentSupervisor));
};
/** @internal */
exports.addSupervisor = addSupervisor;
const enableCooperativeYielding = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.CooperativeYielding)));
};
/** @internal */
exports.enableCooperativeYielding = enableCooperativeYielding;
const enableCurrentFiber = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.CurrentFiber)));
};
/** @internal */
exports.enableCurrentFiber = enableCurrentFiber;
const enableInterruption = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.Interruption)));
};
/** @internal */
exports.enableInterruption = enableInterruption;
const enableFiberRoots = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.FiberRoots)));
};
/** @internal */
exports.enableFiberRoots = enableFiberRoots;
const enableOpSupervision = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.OpSupervision)));
};
/** @internal */
exports.enableOpSupervision = enableOpSupervision;
const enableRuntimeMetrics = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.RuntimeMetrics)));
};
/** @internal */
exports.enableRuntimeMetrics = enableRuntimeMetrics;
const enableWindDown = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.enable(runtimeFlags.WindDown)));
};
/** @internal */
exports.enableWindDown = enableWindDown;
const disableCooperativeYielding = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.CooperativeYielding)));
};
/** @internal */
exports.disableCooperativeYielding = disableCooperativeYielding;
const disableCurrentFiber = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.CurrentFiber)));
};
/** @internal */
exports.disableCurrentFiber = disableCurrentFiber;
const disableInterruption = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.Interruption)));
};
/** @internal */
exports.disableInterruption = disableInterruption;
const disableFiberRoots = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.FiberRoots)));
};
/** @internal */
exports.disableFiberRoots = disableFiberRoots;
const disableOpSupervision = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.OpSupervision)));
};
/** @internal */
exports.disableOpSupervision = disableOpSupervision;
const disableRuntimeMetrics = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.RuntimeMetrics)));
};
/** @internal */
exports.disableRuntimeMetrics = disableRuntimeMetrics;
const disableWindDown = () => {
return layer.scopedDiscard(fiberRuntime.withRuntimeFlagsScoped(runtimeFlagsPatch.disable(runtimeFlags.WindDown)));
};
exports.disableWindDown = disableWindDown;
//# sourceMappingURL=circular.js.map

9

internal/logger.js

@@ -10,6 +10,5 @@ "use strict";

var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));
var FiberId = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Id"));
var FiberRefs = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/FiberRefs"));
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));
var LogLevel = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Logger/Level"));
var _fiberId = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberId"));
var fiberRefs = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/fiberRefs"));
var LogSpan = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Logger/Span"));

@@ -41,3 +40,3 @@ var _Function = /*#__PURE__*/require("@fp-ts/data/Function");

const nowMillis = now.getTime();
const outputArray = [`timestamp=${now.toISOString()}`, `level=${logLevel.label}`, `fiber=${FiberId.threadName(fiberId)}`];
const outputArray = [`timestamp=${now.toISOString()}`, `level=${logLevel.label}`, `fiber=${_fiberId.threadName(fiberId)}`];
if (message.length > 0) {

@@ -149,3 +148,3 @@ outputArray.push(`message="${message}"`);

return self => {
return self.log(FiberId.none, LogLevel.Info, input, Cause.empty, FiberRefs.unsafeMake(new Map()), List.empty(), new Map());
return self.log(_fiberId.none, core.logLevelInfo, input, Cause.empty, fiberRefs.unsafeMake(new Map()), List.empty(), new Map());
};

@@ -152,0 +151,0 @@ };

12

internal/runtime.js

@@ -12,3 +12,2 @@ "use strict";

var FiberId = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Id"));
var RuntimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber/Runtime/Flags"));
var FiberRefs = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/FiberRefs"));

@@ -19,4 +18,5 @@ var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

var OpCodes = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/opCodes/effect"));
var runtimeFlags = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/runtimeFlags"));
var Scheduler = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/scheduler"));
var Supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Supervisor"));
var _supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/supervisor"));
var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Context"));

@@ -46,3 +46,3 @@ var _Function = /*#__PURE__*/require("@fp-ts/data/Function");

const supervisor = fiberRuntime.getSupervisor();
if (supervisor !== Supervisor.none) {
if (supervisor !== _supervisor.none) {
supervisor.onStart(this.context, effect, Option.none, fiberRuntime);

@@ -60,3 +60,3 @@ fiberRuntime.unsafeAddObserver(exit => supervisor.onEnd(exit, fiberRuntime));

const supervisor = fiberRuntime.getSupervisor();
if (supervisor !== Supervisor.none) {
if (supervisor !== _supervisor.none) {
supervisor.onStart(this.context, effect, Option.none, fiberRuntime);

@@ -85,3 +85,3 @@ fiberRuntime.unsafeAddObserver(exit => supervisor.onEnd(exit, fiberRuntime));

const supervisor = fiberRuntime.getSupervisor();
if (supervisor !== Supervisor.none) {
if (supervisor !== _supervisor.none) {
supervisor.onStart(this.context, effect, Option.none, fiberRuntime);

@@ -142,3 +142,3 @@ fiberRuntime.unsafeAddObserver(exit => supervisor.onEnd(exit, fiberRuntime));

exports.runtime = runtime;
const defaultRuntimeFlags = /*#__PURE__*/RuntimeFlags.make(RuntimeFlags.FiberRoots, RuntimeFlags.Interruption, RuntimeFlags.CooperativeYielding);
const defaultRuntimeFlags = /*#__PURE__*/runtimeFlags.make(runtimeFlags.FiberRoots, runtimeFlags.Interruption, runtimeFlags.CooperativeYielding);
/** @internal */

@@ -145,0 +145,0 @@ exports.defaultRuntimeFlags = defaultRuntimeFlags;

12

internal/schedule.js

@@ -79,3 +79,3 @@ "use strict";

{
return core.failSync(() => new Cause.NoSuchElementException());
return core.failSync(() => Cause.NoSuchElementException());
}

@@ -281,3 +281,3 @@ case "Some":

if (!Number.isInteger(day) || day < 1 || 31 < day) {
return core.dieSync(() => new Cause.IllegalArgumentException(`Invalid argument in: dayOfMonth(${day}). Must be in range 1...31`)).traced(trace);
return core.dieSync(() => Cause.IllegalArgumentException(`Invalid argument in: dayOfMonth(${day}). Must be in range 1...31`)).traced(trace);
}

@@ -299,3 +299,3 @@ const n = state[1];

if (!Number.isInteger(day) || day < 1 || 7 < day) {
return core.dieSync(() => new Cause.IllegalArgumentException(`Invalid argument in: dayOfWeek(${day}). Must be in range 1 (Monday)...7 (Sunday)`)).traced(trace);
return core.dieSync(() => Cause.IllegalArgumentException(`Invalid argument in: dayOfWeek(${day}). Must be in range 1 (Monday)...7 (Sunday)`)).traced(trace);
}

@@ -502,3 +502,3 @@ const n = state[1];

if (!Number.isInteger(hour) || hour < 0 || 23 < hour) {
return core.dieSync(() => new Cause.IllegalArgumentException(`Invalid argument in: hourOfDay(${hour}). Must be in range 0...23`)).traced(trace);
return core.dieSync(() => Cause.IllegalArgumentException(`Invalid argument in: hourOfDay(${hour}). Must be in range 0...23`)).traced(trace);
}

@@ -607,3 +607,3 @@ const n = state[1];

if (!Number.isInteger(minute) || minute < 0 || 59 < minute) {
return core.dieSync(() => new Cause.IllegalArgumentException(`Invalid argument in: minuteOfHour(${minute}). Must be in range 0...59`)).traced(trace);
return core.dieSync(() => Cause.IllegalArgumentException(`Invalid argument in: minuteOfHour(${minute}). Must be in range 0...59`)).traced(trace);
}

@@ -856,3 +856,3 @@ const n = state[1];

if (!Number.isInteger(second) || second < 0 || 59 < second) {
return core.dieSync(() => new Cause.IllegalArgumentException(`Invalid argument in: secondOfMinute(${second}). Must be in range 0...59`));
return core.dieSync(() => Cause.IllegalArgumentException(`Invalid argument in: secondOfMinute(${second}). Must be in range 0...59`));
}

@@ -859,0 +859,0 @@ const n = state[1];

11

internal/supervisor/patch.js

@@ -7,4 +7,3 @@ "use strict";

exports.patch = exports.empty = exports.differ = exports.diff = exports.combine = exports.OP_REMOVE_SUPERVISOR = exports.OP_EMPTY = exports.OP_AND_THEN = exports.OP_ADD_SUPERVISOR = void 0;
var _supervisor2 = /*#__PURE__*/require("@effect/io/internal/supervisor");
var Supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Supervisor"));
var supervisor = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/supervisor"));
var Differ = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Differ"));

@@ -96,5 +95,5 @@ var Equal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Equal"));

if (Equal.equals(self, that)) {
return Supervisor.none;
return supervisor.none;
} else {
if (self instanceof _supervisor2.Zip) {
if (self instanceof supervisor.Zip) {
return removeSupervisor(self.left, that).zip(removeSupervisor(self.right, that));

@@ -108,6 +107,6 @@ } else {

const toSet = self => {
if (Equal.equals(self, Supervisor.none)) {
if (Equal.equals(self, supervisor.none)) {
return HashSet.empty();
} else {
if (self instanceof _supervisor2.Zip) {
if (self instanceof supervisor.Zip) {
return HashSet.union(toSet(self.right))(toSet(self.left));

@@ -114,0 +113,0 @@ } else {

69

Layer.d.ts

@@ -20,3 +20,8 @@ /**

*/
import * as internal from "@effect/io/internal/layer";
import type * as Cause from "@effect/io/Cause";
import type * as Effect from "@effect/io/Effect";
import type * as Runtime from "@effect/io/Runtime";
import type * as Schedule from "@effect/io/Schedule";
import type * as Scope from "@effect/io/Scope";
import type * as Context from "@fp-ts/data/Context";
/**

@@ -76,3 +81,3 @@ * @since 1.0.0

*/
export declare const build: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => import("./Effect").Effect<import("./Scope").Scope | RIn, E, import("@fp-ts/data/Context").Context<ROut>>;
export declare const build: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Effect.Effect<Scope.Scope | RIn, E, Context.Context<ROut>>;
/**

@@ -89,3 +94,3 @@ * Builds a layer into an `Effect` value. Any resources associated with this

*/
export declare const buildWithScope: (scope: import("./Scope").Scope) => <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => import("./Effect").Effect<RIn, E, import("@fp-ts/data/Context").Context<ROut>>;
export declare const buildWithScope: (scope: Scope.Scope) => <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Effect.Effect<RIn, E, Context.Context<ROut>>;
/**

@@ -129,3 +134,3 @@ * Recovers from all errors.

*/
export declare const extendScope: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Layer<import("./Scope").Scope | RIn, E, ROut>;
export declare const extendScope: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Layer<Scope.Scope | RIn, E, ROut>;
/**

@@ -151,3 +156,3 @@ * Constructs a layer that fails with the specified error.

*/
export declare const failCause: <E>(cause: import("./Cause").Cause<E>) => Layer<never, E, unknown>;
export declare const failCause: <E>(cause: Cause.Cause<E>) => Layer<never, E, unknown>;
/**

@@ -159,3 +164,3 @@ * Constructs a layer that fails with the specified cause.

*/
export declare const failCauseSync: <E>(evaluate: () => import("./Cause").Cause<E>) => Layer<never, E, unknown>;
export declare const failCauseSync: <E>(evaluate: () => Cause.Cause<E>) => Layer<never, E, unknown>;
/**

@@ -167,3 +172,3 @@ * Constructs a layer dynamically based on the output of this layer.

*/
export declare const flatMap: <A, R2, E2, A2>(f: (context: import("@fp-ts/data/Context").Context<A>) => Layer<R2, E2, A2>) => <R, E>(self: Layer<R, E, A>) => Layer<R2 | R, E2 | E, A2>;
export declare const flatMap: <A, R2, E2, A2>(f: (context: Context.Context<A>) => Layer<R2, E2, A2>) => <R, E>(self: Layer<R, E, A>) => Layer<R2 | R, E2 | E, A2>;
/**

@@ -175,3 +180,3 @@ * Flattens layers nested in the environment of an effect.

*/
export declare const flatten: <R2, E2, A>(tag: import("@fp-ts/data/Context").Tag<Layer<R2, E2, A>>) => <R, E>(self: Layer<R, E, Layer<R2, E2, A>>) => Layer<R2 | R, E2 | E, A>;
export declare const flatten: <R2, E2, A>(tag: Context.Tag<Layer<R2, E2, A>>) => <R, E>(self: Layer<R, E, Layer<R2, E2, A>>) => Layer<R2 | R, E2 | E, A>;
/**

@@ -185,3 +190,3 @@ * Feeds the error or output services of this layer into the input of either

*/
export declare const foldLayer: <E, R2, E2, A2, A, R3, E3, A3>(onFailure: (error: E) => Layer<R2, E2, A2>, onSuccess: (context: import("@fp-ts/data/Context").Context<A>) => Layer<R3, E3, A3>) => <R>(self: Layer<R, E, A>) => Layer<R2 | R3 | R, E2 | E3, A2 & A3>;
export declare const foldLayer: <E, R2, E2, A2, A, R3, E3, A3>(onFailure: (error: E) => Layer<R2, E2, A2>, onSuccess: (context: Context.Context<A>) => Layer<R3, E3, A3>) => <R>(self: Layer<R, E, A>) => Layer<R2 | R3 | R, E2 | E3, A2 & A3>;
/**

@@ -195,3 +200,3 @@ * Feeds the error or output services of this layer into the input of either

*/
export declare const foldCauseLayer: <E, A, R2, E2, A2, R3, E3, A3>(onFailure: (cause: import("./Cause").Cause<E>) => Layer<R2, E2, A2>, onSuccess: (context: import("@fp-ts/data/Context").Context<A>) => Layer<R3, E3, A3>) => <R>(self: Layer<R, E, A>) => Layer<R2 | R3 | R, E2 | E3, A2 | A3>;
export declare const foldCauseLayer: <E, A, R2, E2, A2, R3, E3, A3>(onFailure: (cause: Cause.Cause<E>) => Layer<R2, E2, A2>, onSuccess: (context: Context.Context<A>) => Layer<R3, E3, A3>) => <R>(self: Layer<R, E, A>) => Layer<R2 | R3 | R, E2 | E3, A2 | A3>;
/**

@@ -210,3 +215,3 @@ * Creates a fresh version of this layer that will not be shared.

*/
export declare const fromEffect: typeof internal.fromEffect;
export declare const fromEffect: <T>(tag: Context.Tag<T>) => <R, E>(effect: Effect.Effect<R, E, T>) => Layer<R, E, T>;
/**

@@ -219,3 +224,3 @@ * Constructs a layer from the specified effect, which must return one or more

*/
export declare const fromEffectEnvironment: typeof internal.fromEffectEnvironment;
export declare const fromEffectEnvironment: <R, E, A>(effect: Effect.Effect<R, E, Context.Context<A>>) => Layer<R, E, A>;
/**

@@ -227,3 +232,3 @@ * Constructs a layer from the environment using the specified function.

*/
export declare const fromFunction: <A, B>(tagA: import("@fp-ts/data/Context").Tag<A>, tagB: import("@fp-ts/data/Context").Tag<B>) => (f: (a: A) => B) => Layer<A, never, B>;
export declare const fromFunction: <A, B>(tagA: Context.Tag<A>, tagB: Context.Tag<B>) => (f: (a: A) => B) => Layer<A, never, B>;
/**

@@ -236,3 +241,3 @@ * Builds this layer and uses it until it is interrupted. This is useful when

*/
export declare const launch: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => import("./Effect").Effect<RIn, E, never>;
export declare const launch: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Effect.Effect<RIn, E, never>;
/**

@@ -244,3 +249,3 @@ * Returns a new layer whose output is mapped by the specified function.

*/
export declare const map: <A, B>(f: (context: import("@fp-ts/data/Context").Context<A>) => import("@fp-ts/data/Context").Context<B>) => <R, E>(self: Layer<R, E, A>) => Layer<R, E, B>;
export declare const map: <A, B>(f: (context: Context.Context<A>) => Context.Context<B>) => <R, E>(self: Layer<R, E, A>) => Layer<R, E, B>;
/**

@@ -261,3 +266,3 @@ * Returns a layer with its error channel mapped using the specified function.

*/
export declare const memoize: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => import("./Effect").Effect<import("./Scope").Scope, never, Layer<RIn, E, ROut>>;
export declare const memoize: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Effect.Effect<Scope.Scope, never, Layer<RIn, E, ROut>>;
/**

@@ -302,3 +307,3 @@ * Combines this layer with the specified layer, producing a new layer that

*/
export declare const project: <A, B>(tagA: import("@fp-ts/data/Context").Tag<A>, tagB: import("@fp-ts/data/Context").Tag<B>) => (f: (a: A) => B) => <RIn, E, ROut>(self: Layer<RIn, E, A | ROut>) => Layer<RIn, E, B>;
export declare const project: <A, B>(tagA: Context.Tag<A>, tagB: Context.Tag<B>) => (f: (a: A) => B) => <RIn, E, ROut>(self: Layer<RIn, E, A | ROut>) => Layer<RIn, E, B>;
/**

@@ -321,3 +326,3 @@ * Feeds the output services of this builder into the input of the specified

*/
export declare const provideToAndMerge: typeof internal.provideToAndMerge;
export declare const provideToAndMerge: <RIn2, E2, ROut2>(that: Layer<RIn2, E2, ROut2>) => <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn | Exclude<RIn2, ROut>, E2 | E, ROut2 | ROut>;
/**

@@ -329,3 +334,3 @@ * Retries constructing this layer according to the specified schedule.

*/
export declare const retry: <RIn1, E, X>(schedule: import("./Schedule").Schedule<RIn1, E, X>) => <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn1 | RIn, E, ROut>;
export declare const retry: <RIn1, E, X>(schedule: Schedule.Schedule<RIn1, E, X>) => <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn1 | RIn, E, ROut>;
/**

@@ -340,3 +345,3 @@ * A layer that constructs a scope and closes it when the workflow the layer

*/
export declare const scope: () => Layer<never, never, import("./Scope").CloseableScope>;
export declare const scope: () => Layer<never, never, Scope.CloseableScope>;
/**

@@ -348,3 +353,3 @@ * Constructs a layer from the specified scoped effect.

*/
export declare const scoped: <T>(tag: import("@fp-ts/data/Context").Tag<T>) => <R, E, T1 extends T>(effect: import("./Effect").Effect<R, E, T1>) => Layer<Exclude<R, import("./Scope").Scope>, E, T>;
export declare const scoped: <T>(tag: Context.Tag<T>) => <R, E, T1 extends T>(effect: Effect.Effect<R, E, T1>) => Layer<Exclude<R, Scope.Scope>, E, T>;
/**

@@ -356,3 +361,3 @@ * Constructs a layer from the specified scoped effect.

*/
export declare const scopedDiscard: <R, E, T>(effect: import("./Effect").Effect<R, E, T>) => Layer<Exclude<R, import("./Scope").Scope>, E, never>;
export declare const scopedDiscard: <R, E, T>(effect: Effect.Effect<R, E, T>) => Layer<Exclude<R, Scope.Scope>, E, never>;
/**

@@ -365,3 +370,3 @@ * Constructs a layer from the specified scoped effect, which must return one

*/
export declare const scopedEnvironment: <R, E, A>(effect: import("./Effect").Effect<R, E, import("@fp-ts/data/Context").Context<A>>) => Layer<Exclude<R, import("./Scope").Scope>, E, A>;
export declare const scopedEnvironment: <R, E, A>(effect: Effect.Effect<R, E, Context.Context<A>>) => Layer<Exclude<R, Scope.Scope>, E, A>;
/**

@@ -374,3 +379,3 @@ * Constructs a layer that accesses and returns the specified service from the

*/
export declare const service: <T>(tag: import("@fp-ts/data/Context").Tag<T>) => Layer<T, never, T>;
export declare const service: <T>(tag: Context.Tag<T>) => Layer<T, never, T>;
/**

@@ -382,3 +387,3 @@ * Constructs a layer from the specified value.

*/
export declare const succeed: <T>(tag: import("@fp-ts/data/Context").Tag<T>) => (resource: T) => Layer<never, never, T>;
export declare const succeed: <T>(tag: Context.Tag<T>) => (resource: T) => Layer<never, never, T>;
/**

@@ -391,3 +396,3 @@ * Constructs a layer from the specified value, which must return one or more

*/
export declare const succeedEnvironment: <A>(environment: import("@fp-ts/data/Context").Context<A>) => Layer<never, never, A>;
export declare const succeedEnvironment: <A>(environment: Context.Context<A>) => Layer<never, never, A>;
/**

@@ -407,3 +412,3 @@ * Lazily constructs a layer. This is useful to avoid infinite recursion when

*/
export declare const sync: <T>(tag: import("@fp-ts/data/Context").Tag<T>) => (evaluate: () => T) => Layer<never, never, T>;
export declare const sync: <T>(tag: Context.Tag<T>) => (evaluate: () => T) => Layer<never, never, T>;
/**

@@ -416,3 +421,3 @@ * Lazily constructs a layer from the specified value, which must return one or more

*/
export declare const syncEnvironment: <A>(evaluate: () => import("@fp-ts/data/Context").Context<A>) => Layer<never, never, A>;
export declare const syncEnvironment: <A>(evaluate: () => Context.Context<A>) => Layer<never, never, A>;
/**

@@ -424,3 +429,3 @@ * Performs the specified effect if this layer succeeds.

*/
export declare const tap: <ROut, RIn2, E2, X>(f: (context: import("@fp-ts/data/Context").Context<ROut>) => import("./Effect").Effect<RIn2, E2, X>) => <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>;
export declare const tap: <ROut, RIn2, E2, X>(f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>) => <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>;
/**

@@ -432,3 +437,3 @@ * Performs the specified effect if this layer fails.

*/
export declare const tapError: <E, RIn2, E2, X>(f: (e: E) => import("./Effect").Effect<RIn2, E2, X>) => <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>;
export declare const tapError: <E, RIn2, E2, X>(f: (e: E) => Effect.Effect<RIn2, E2, X>) => <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>;
/**

@@ -441,3 +446,3 @@ * Converts a layer that requires no services into a scoped runtime, which can

*/
export declare const toRuntime: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => import("./Effect").Effect<import("./Scope").Scope | RIn, E, import("./Runtime").Runtime<ROut>>;
export declare const toRuntime: <RIn, E, ROut>(self: Layer<RIn, E, ROut>) => Effect.Effect<Scope.Scope | RIn, E, Runtime.Runtime<ROut>>;
/**

@@ -451,3 +456,3 @@ * Combines this layer the specified layer, producing a new layer that has the

*/
export declare const zipWithPar: typeof internal.zipWithPar;
export declare const zipWithPar: <R1, E1, A1, A, A2>(that: Layer<R1, E1, A1>, f: (a: Context.Context<A>, b: Context.Context<A1>) => Context.Context<A2>) => <R, E>(self: Layer<R, E, A>) => Layer<R1 | R, E1 | E, A2>;
//# sourceMappingURL=Layer.d.ts.map

20

Layer.js

@@ -11,23 +11,3 @@ "use strict";

/**
* A `Layer<RIn, E, ROut>` describes how to build one or more services in your
* application. Services can be injected into effects via
* `Effect.provideService`. Effects can require services via `Effect.service`.
*
* Layer can be thought of as recipes for producing bundles of services, given
* their dependencies (other services).
*
* Construction of services can be effectful and utilize resources that must be
* acquired and safely released when the services are done being utilized.
*
* By default layers are shared, meaning that if the same layer is used twice
* the layer will only be allocated a single time.
*
* Because of their excellent composition properties, layers are the idiomatic
* way in Effect-TS to create services that depend on other services.
*
* @since 1.0.0
*/
/**
* @since 1.0.0
* @category symbols

@@ -34,0 +14,0 @@ */

25

Logger.d.ts

@@ -7,6 +7,7 @@ /**

import type * as FiberRefs from "@effect/io/FiberRefs";
import * as internal from "@effect/io/internal/logger";
import type * as Layer from "@effect/io/Layer";
import type * as LogLevel from "@effect/io/Logger/Level";
import type * as LogSpan from "@effect/io/Logger/Span";
import type * as List from "@fp-ts/data/List";
import type * as Option from "@fp-ts/data/Option";
/**

@@ -46,5 +47,5 @@ * @since 1.0.0

* @since 1.0.0
* @category constructors
* @category environment
*/
export declare const consoleLogger: () => Logger<string, void>;
export declare const addLogger: <B>(logger: Logger<string, B>) => Layer.Layer<never, never, never>;
/**

@@ -54,3 +55,3 @@ * @since 1.0.0

*/
export declare const defaultLogger: Logger<string, string>;
export declare const consoleLogger: () => Logger<string, void>;
/**

@@ -60,3 +61,3 @@ * @since 1.0.0

*/
export declare const console: (minLevel?: LogLevel.LogLevel) => import("./Layer").Layer<never, never, never>;
export declare const console: (minLevel?: LogLevel.LogLevel) => Layer.Layer<never, never, never>;
/**

@@ -66,4 +67,9 @@ * @since 1.0.0

*/
export declare const contramap: typeof internal.contramap;
export declare const contramap: <Message, Message2>(f: (message: Message2) => Message) => <Output>(self: Logger<Message, Output>) => Logger<Message2, Output>;
/**
* @since 1.0.0
* @category constructors
*/
export declare const defaultLogger: Logger<string, string>;
/**
* Returns a version of this logger that only logs messages when the log level

@@ -75,10 +81,5 @@ * satisfies the specified predicate.

*/
export declare const filterLogLevel: (f: (logLevel: LogLevel.LogLevel) => boolean) => <Message, Output>(self: Logger<Message, Output>) => Logger<Message, import("@fp-ts/data/Option").Option<Output>>;
export declare const filterLogLevel: (f: (logLevel: LogLevel.LogLevel) => boolean) => <Message, Output>(self: Logger<Message, Output>) => Logger<Message, Option.Option<Output>>;
/**
* @since 1.0.0
* @category environment
*/
export declare const layer: <B>(logger: Logger<string, B>) => import("./Layer").Layer<never, never, never>;
/**
* @since 1.0.0
* @category mapping

@@ -85,0 +86,0 @@ */

28

Logger.js

@@ -6,3 +6,3 @@ "use strict";

});
exports.zipRight = exports.zipLeft = exports.zip = exports.test = exports.sync = exports.succeed = exports.simple = exports.none = exports.map = exports.layer = exports.filterLogLevel = exports.defaultLogger = exports.contramap = exports.consoleLogger = exports.console = exports.LoggerTypeId = void 0;
exports.zipRight = exports.zipLeft = exports.zip = exports.test = exports.sync = exports.succeed = exports.simple = exports.none = exports.map = exports.filterLogLevel = exports.defaultLogger = exports.contramap = exports.consoleLogger = exports.console = exports.addLogger = exports.LoggerTypeId = void 0;
var circular = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/layer/circular"));

@@ -19,6 +19,6 @@ var internal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/logger"));

* @since 1.0.0
* @category constructors
* @category environment
*/
exports.LoggerTypeId = LoggerTypeId;
const consoleLogger = internal.consoleLogger;
const addLogger = circular.addLogger;
/**

@@ -28,4 +28,4 @@ * @since 1.0.0

*/
exports.consoleLogger = consoleLogger;
const defaultLogger = internal.defaultLogger;
exports.addLogger = addLogger;
const consoleLogger = internal.consoleLogger;
/**

@@ -35,3 +35,3 @@ * @since 1.0.0

*/
exports.defaultLogger = defaultLogger;
exports.consoleLogger = consoleLogger;
const console = circular.consoleLoggerLayer;

@@ -45,2 +45,8 @@ /**

/**
* @since 1.0.0
* @category constructors
*/
exports.contramap = contramap;
const defaultLogger = internal.defaultLogger;
/**
* Returns a version of this logger that only logs messages when the log level

@@ -52,15 +58,9 @@ * satisfies the specified predicate.

*/
exports.contramap = contramap;
exports.defaultLogger = defaultLogger;
const filterLogLevel = internal.filterLogLevel;
/**
* @since 1.0.0
* @category environment
* @category mapping
*/
exports.filterLogLevel = filterLogLevel;
const layer = circular.loggerLayer;
/**
* @since 1.0.0
* @category mapping
*/
exports.layer = layer;
const map = internal.map;

@@ -67,0 +67,0 @@ /**

56

Logger/Level.js

@@ -17,8 +17,3 @@ "use strict";

*/
const All = {
_tag: "All",
syslog: 0,
label: "ALL",
ordinal: Number.MIN_SAFE_INTEGER
};
const All = core.logLevelAll;
/**

@@ -29,8 +24,3 @@ * @since 1.0.0

exports.All = All;
const Fatal = {
_tag: "Fatal",
syslog: 2,
label: "FATAL",
ordinal: 50000
};
const Fatal = core.logLevelFatal;
/**

@@ -41,8 +31,3 @@ * @since 1.0.0

exports.Fatal = Fatal;
const Error = {
_tag: "Error",
syslog: 3,
label: "ERROR",
ordinal: 40000
};
const Error = core.logLevelError;
/**

@@ -53,8 +38,3 @@ * @since 1.0.0

exports.Error = Error;
const Warning = {
_tag: "Warning",
syslog: 4,
label: "WARN",
ordinal: 30000
};
const Warning = core.logLevelWarning;
/**

@@ -65,8 +45,3 @@ * @since 1.0.0

exports.Warning = Warning;
const Info = {
_tag: "Info",
syslog: 6,
label: "INFO",
ordinal: 20000
};
const Info = core.logLevelInfo;
/**

@@ -77,8 +52,3 @@ * @since 1.0.0

exports.Info = Info;
const Debug = {
_tag: "Debug",
syslog: 7,
label: "DEBUG",
ordinal: 10000
};
const Debug = core.logLevelDebug;
/**

@@ -89,8 +59,3 @@ * @since 1.0.0

exports.Debug = Debug;
const Trace = {
_tag: "Trace",
syslog: 7,
label: "TRACE",
ordinal: 0
};
const Trace = core.logLevelTrace;
/**

@@ -101,8 +66,3 @@ * @since 1.0.0

exports.Trace = Trace;
const None = {
_tag: "None",
syslog: 7,
label: "OFF",
ordinal: Number.MAX_SAFE_INTEGER
};
const None = core.logLevelNone;
/**

@@ -109,0 +69,0 @@ * Locally applies the specified `LogLevel` to an `Effect` workflow, reverting

25

Metric.d.ts

@@ -5,6 +5,11 @@ /**

import type * as Effect from "@effect/io/Effect";
import * as internal from "@effect/io/internal/metric";
import type * as MetricBoundaries from "@effect/io/Metric/Boundaries";
import type * as MetricKey from "@effect/io/Metric/Key";
import type * as MetricKeyType from "@effect/io/Metric/KeyType";
import type * as MetricLabel from "@effect/io/Metric/Label";
import type * as MetricPair from "@effect/io/Metric/Pair";
import type * as MetricRegistry from "@effect/io/Metric/Registry";
import type * as MetricState from "@effect/io/Metric/State";
import type * as Chunk from "@fp-ts/data/Chunk";
import type * as Duration from "@fp-ts/data/Duration";
import type * as HashSet from "@fp-ts/data/HashSet";

@@ -106,3 +111,3 @@ /**

*/
export declare const globalMetricRegistry: import("./Metric/Registry").MetricRegistry;
export declare const globalMetricRegistry: MetricRegistry.MetricRegistry;
/**

@@ -150,3 +155,3 @@ * @since 1.0.0

*/
export declare const fromMetricKey: <Type extends MetricKeyType.MetricKeyType<any, any>>(key: import("./Metric/Key").MetricKey<Type>) => Metric<Type, MetricKeyType.MetricKeyType.InType<Type>, MetricKeyType.MetricKeyType.OutType<Type>>;
export declare const fromMetricKey: <Type extends MetricKeyType.MetricKeyType<any, any>>(key: MetricKey.MetricKey<Type>) => Metric<Type, MetricKeyType.MetricKeyType.InType<Type>, MetricKeyType.MetricKeyType.OutType<Type>>;
/**

@@ -166,3 +171,3 @@ * A gauge, which can be set to a value.

*/
export declare const histogram: (name: string, boundaries: import("./Metric/Boundaries").MetricBoundaries) => Metric<MetricKeyType.MetricKeyType.Histogram, number, MetricState.MetricState.Histogram>;
export declare const histogram: (name: string, boundaries: MetricBoundaries.MetricBoundaries) => Metric<MetricKeyType.MetricKeyType.Histogram, number, MetricState.MetricState.Histogram>;
/**

@@ -218,3 +223,3 @@ * @macro traced

*/
export declare const summary: (name: string, maxAge: import("@fp-ts/data/Duration").Duration, maxSize: number, error: number, quantiles: import("@fp-ts/data/Chunk").Chunk<number>) => Metric.Summary<number>;
export declare const summary: (name: string, maxAge: Duration.Duration, maxSize: number, error: number, quantiles: Chunk.Chunk<number>) => Metric.Summary<number>;
/**

@@ -224,3 +229,3 @@ * @since 1.0.0

*/
export declare const summaryTimestamp: (name: string, maxAge: import("@fp-ts/data/Duration").Duration, maxSize: number, error: number, quantiles: import("@fp-ts/data/Chunk").Chunk<number>) => Metric.Summary<readonly [value: number, timestamp: number]>;
export declare const summaryTimestamp: (name: string, maxAge: Duration.Duration, maxSize: number, error: number, quantiles: Chunk.Chunk<number>) => Metric.Summary<readonly [value: number, timestamp: number]>;
/**

@@ -268,3 +273,3 @@ * Returns a new metric, which is identical in every way to this one, except

*/
export declare const timer: (name: string) => Metric<MetricKeyType.MetricKeyType.Histogram, import("@fp-ts/data/Duration").Duration, MetricState.MetricState.Histogram>;
export declare const timer: (name: string) => Metric<MetricKeyType.MetricKeyType.Histogram, Duration.Duration, MetricState.MetricState.Histogram>;
/**

@@ -308,3 +313,3 @@ * Returns an aspect that will update this metric with the specified constant

*/
export declare const trackDuration: <Type, Out>(self: Metric<Type, import("@fp-ts/data/Duration").Duration, Out>) => <R, E, A>(effect: Effect.Effect<R, E, A>) => Effect.Effect<R, E, A>;
export declare const trackDuration: <Type, Out>(self: Metric<Type, Duration.Duration, Out>) => <R, E, A>(effect: Effect.Effect<R, E, A>) => Effect.Effect<R, E, A>;
/**

@@ -319,3 +324,3 @@ * Returns an aspect that will update this metric with the duration that the

*/
export declare const trackDurationWith: <In>(f: (duration: import("@fp-ts/data/Duration").Duration) => In) => <Type, Out>(self: Metric<Type, In, Out>) => <R, E, A>(effect: Effect.Effect<R, E, A>) => Effect.Effect<R, E, A>;
export declare const trackDurationWith: <In>(f: (duration: Duration.Duration) => In) => <Type, Out>(self: Metric<Type, In, Out>) => <R, E, A>(effect: Effect.Effect<R, E, A>) => Effect.Effect<R, E, A>;
/**

@@ -393,3 +398,3 @@ * Returns an aspect that will update this metric with the failure value of

*/
export declare const unsafeSnapshot: typeof internal.unsafeSnapshot;
export declare const unsafeSnapshot: () => HashSet.HashSet<MetricPair.MetricPair.Untyped>;
//# sourceMappingURL=Metric.d.ts.map

11

Metric/Hook.d.ts

@@ -0,1 +1,2 @@

import type * as MetricKey from "@effect/io/Metric/Key";
import type * as MetricState from "@effect/io/Metric/State";

@@ -79,3 +80,3 @@ /**

*/
export declare const counter: (_key: import("./Key").MetricKey.Counter) => MetricHook.Counter;
export declare const counter: (_key: MetricKey.MetricKey.Counter) => MetricHook.Counter;
/**

@@ -85,3 +86,3 @@ * @since 1.0.0

*/
export declare const frequency: (_key: import("./Key").MetricKey.Frequency) => MetricHook.Frequency;
export declare const frequency: (_key: MetricKey.MetricKey.Frequency) => MetricHook.Frequency;
/**

@@ -91,3 +92,3 @@ * @since 1.0.0

*/
export declare const gauge: (_key: import("./Key").MetricKey.Gauge, startAt: number) => MetricHook.Gauge;
export declare const gauge: (_key: MetricKey.MetricKey.Gauge, startAt: number) => MetricHook.Gauge;
/**

@@ -97,3 +98,3 @@ * @since 1.0.0

*/
export declare const histogram: (key: import("./Key").MetricKey.Histogram) => MetricHook.Histogram;
export declare const histogram: (key: MetricKey.MetricKey.Histogram) => MetricHook.Histogram;
/**

@@ -103,3 +104,3 @@ * @since 1.0.0

*/
export declare const summary: (key: import("./Key").MetricKey.Summary) => MetricHook.Summary;
export declare const summary: (key: MetricKey.MetricKey.Summary) => MetricHook.Summary;
/**

@@ -106,0 +107,0 @@ * @since 1.0.0

7

Metric/Key.d.ts

@@ -0,3 +1,6 @@

import type * as MetricBoundaries from "@effect/io/Metric/Boundaries";
import type * as MetricKeyType from "@effect/io/Metric/KeyType";
import type * as MetricLabel from "@effect/io/Metric/Label";
import type * as Chunk from "@fp-ts/data/Chunk";
import type * as Duration from "@fp-ts/data/Duration";
import type * as Equal from "@fp-ts/data/Equal";

@@ -107,3 +110,3 @@ import type * as HashSet from "@fp-ts/data/HashSet";

*/
export declare const histogram: (name: string, boundaries: import("./Boundaries").MetricBoundaries) => MetricKey.Histogram;
export declare const histogram: (name: string, boundaries: MetricBoundaries.MetricBoundaries) => MetricKey.Histogram;
/**

@@ -116,3 +119,3 @@ * Creates a metric key for a summary, with the specified name, maxAge,

*/
export declare const summary: (name: string, maxAge: import("@fp-ts/data/Duration").Duration, maxSize: number, error: number, quantiles: import("@fp-ts/data/Chunk").Chunk<number>) => MetricKey.Summary;
export declare const summary: (name: string, maxAge: Duration.Duration, maxSize: number, error: number, quantiles: Chunk.Chunk<number>) => MetricKey.Summary;
/**

@@ -119,0 +122,0 @@ * Returns a new `MetricKey` with the specified tag appended.

10

Metric/Polling.d.ts

@@ -5,3 +5,7 @@ /**

import type * as Effect from "@effect/io/Effect";
import type * as Fiber from "@effect/io/Fiber";
import type * as Metric from "@effect/io/Metric";
import type * as Schedule from "@effect/io/Schedule";
import type * as Scope from "@effect/io/Scope";
import type * as Chunk from "@fp-ts/data/Chunk";
/**

@@ -51,3 +55,3 @@ * @since 1.0.0

*/
export declare const collectAll: <R, E, Out>(iterable: Iterable<PollingMetric<any, any, R, E, Out>>) => PollingMetric<import("@fp-ts/data/Chunk").Chunk<any>, import("@fp-ts/data/Chunk").Chunk<any>, R, E, import("@fp-ts/data/Chunk").Chunk<Out>>;
export declare const collectAll: <R, E, Out>(iterable: Iterable<PollingMetric<any, any, R, E, Out>>) => PollingMetric<Chunk.Chunk<any>, Chunk.Chunk<any>, R, E, Chunk.Chunk<Out>>;
/**

@@ -61,3 +65,3 @@ * Returns an effect that will launch the polling metric in a background

*/
export declare const launch: <R2, A2>(schedule: import("../Schedule").Schedule<R2, unknown, A2>) => <Type, In, R, E, Out>(self: PollingMetric<Type, In, R, E, Out>) => Effect.Effect<import("../Scope").Scope | R2 | R, never, import("../Fiber").Fiber<E, A2>>;
export declare const launch: <R2, A2>(schedule: Schedule.Schedule<R2, unknown, A2>) => <Type, In, R, E, Out>(self: PollingMetric<Type, In, R, E, Out>) => Effect.Effect<R2 | R | Scope.Scope, never, Fiber.Fiber<E, A2>>;
/**

@@ -86,3 +90,3 @@ * An effect that polls a value that may be fed to the metric.

*/
export declare const retry: <R2, E, _>(policy: import("../Schedule").Schedule<R2, E, _>) => <Type, In, R, Out>(self: PollingMetric<Type, In, R, E, Out>) => PollingMetric<Type, In, R2 | R, E, Out>;
export declare const retry: <R2, E, _>(policy: Schedule.Schedule<R2, E, _>) => <Type, In, R, Out>(self: PollingMetric<Type, In, R, E, Out>) => PollingMetric<Type, In, R2 | R, E, Out>;
/**

@@ -89,0 +93,0 @@ * Zips this polling metric with the specified polling metric.

2

package.json
{
"name": "@effect/io",
"version": "0.0.2",
"version": "0.0.3",
"license": "MIT",

@@ -5,0 +5,0 @@ "repository": {

3

Queue.d.ts

@@ -9,2 +9,3 @@ /**

import type * as MutableRef from "@fp-ts/data/mutable/MutableRef";
import type * as Option from "@fp-ts/data/Option";
/**

@@ -412,3 +413,3 @@ * @since 1.0.0

*/
export declare const poll: <A>(self: Dequeue<A>) => Effect.Effect<never, never, import("@fp-ts/data/Option").Option<A>>;
export declare const poll: <A>(self: Dequeue<A>) => Effect.Effect<never, never, Option.Option<A>>;
/**

@@ -415,0 +416,0 @@ * Takes the oldest value in the queue. If the queue is empty, this will return

9

Ref.d.ts

@@ -5,2 +5,3 @@ /**

import type * as Effect from "@effect/io/Effect";
import type * as Option from "@fp-ts/data/Option";
/**

@@ -66,3 +67,3 @@ * @since 1.0.0

*/
export declare const getAndUpdateSome: <A>(pf: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: Ref<A>) => Effect.Effect<never, never, A>;
export declare const getAndUpdateSome: <A>(pf: (a: A) => Option.Option<A>) => (self: Ref<A>) => Effect.Effect<never, never, A>;
/**

@@ -79,3 +80,3 @@ * @macro traced

*/
export declare const modifySome: <A, B>(fallback: B, pf: (a: A) => import("@fp-ts/data/Option").Option<readonly [B, A]>) => (self: Ref<A>) => Effect.Effect<never, never, B>;
export declare const modifySome: <A, B>(fallback: B, pf: (a: A) => Option.Option<readonly [B, A]>) => (self: Ref<A>) => Effect.Effect<never, never, B>;
/**

@@ -110,3 +111,3 @@ * @macro traced

*/
export declare const updateSome: <A>(f: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: Ref<A>) => Effect.Effect<never, never, void>;
export declare const updateSome: <A>(f: (a: A) => Option.Option<A>) => (self: Ref<A>) => Effect.Effect<never, never, void>;
/**

@@ -117,3 +118,3 @@ * @macro traced

*/
export declare const updateSomeAndGet: <A>(pf: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: Ref<A>) => Effect.Effect<never, never, A>;
export declare const updateSomeAndGet: <A>(pf: (a: A) => Option.Option<A>) => (self: Ref<A>) => Effect.Effect<never, never, A>;
/**

@@ -120,0 +121,0 @@ * @since 1.0.0

17

Ref/Synchronized.d.ts

@@ -6,2 +6,3 @@ /**

import type * as Ref from "@effect/io/Ref";
import type * as Option from "@fp-ts/data/Option";
/**

@@ -76,3 +77,3 @@ * @since 1.0.0

*/
export declare const getAndUpdateSome: <A>(f: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: Synchronized<A>) => Effect.Effect<never, never, A>;
export declare const getAndUpdateSome: <A>(f: (a: A) => Option.Option<A>) => (self: Synchronized<A>) => Effect.Effect<never, never, A>;
/**

@@ -83,3 +84,3 @@ * @macro traced

*/
export declare const getAndUpdateSomeEffect: <A, R, E>(pf: (a: A) => import("@fp-ts/data/Option").Option<Effect.Effect<R, E, A>>) => (self: Synchronized<A>) => Effect.Effect<R, E, A>;
export declare const getAndUpdateSomeEffect: <A, R, E>(pf: (a: A) => Option.Option<Effect.Effect<R, E, A>>) => (self: Synchronized<A>) => Effect.Effect<R, E, A>;
/**

@@ -102,3 +103,3 @@ * @macro traced

*/
export declare const modifySome: <A, B>(fallback: B, f: (a: A) => import("@fp-ts/data/Option").Option<readonly [B, A]>) => (self: Synchronized<A>) => Effect.Effect<never, never, B>;
export declare const modifySome: <A, B>(fallback: B, f: (a: A) => Option.Option<readonly [B, A]>) => (self: Synchronized<A>) => Effect.Effect<never, never, B>;
/**

@@ -109,3 +110,3 @@ * @macro traced

*/
export declare const modifySomeEffect: <B, A, R, E>(fallback: B, pf: (a: A) => import("@fp-ts/data/Option").Option<Effect.Effect<R, E, readonly [B, A]>>) => (self: Synchronized<A>) => Effect.Effect<R, E, B>;
export declare const modifySomeEffect: <B, A, R, E>(fallback: B, pf: (a: A) => Option.Option<Effect.Effect<R, E, readonly [B, A]>>) => (self: Synchronized<A>) => Effect.Effect<R, E, B>;
/**

@@ -146,3 +147,3 @@ * @macro traced

*/
export declare const updateSome: <A>(f: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: Synchronized<A>) => Effect.Effect<never, never, void>;
export declare const updateSome: <A>(f: (a: A) => Option.Option<A>) => (self: Synchronized<A>) => Effect.Effect<never, never, void>;
/**

@@ -153,3 +154,3 @@ * @macro traced

*/
export declare const updateSomeEffect: <A, R, E>(pf: (a: A) => import("@fp-ts/data/Option").Option<Effect.Effect<R, E, A>>) => (self: Synchronized<A>) => Effect.Effect<R, E, void>;
export declare const updateSomeEffect: <A, R, E>(pf: (a: A) => Option.Option<Effect.Effect<R, E, A>>) => (self: Synchronized<A>) => Effect.Effect<R, E, void>;
/**

@@ -160,3 +161,3 @@ * @macro traced

*/
export declare const updateSomeAndGet: <A>(f: (a: A) => import("@fp-ts/data/Option").Option<A>) => (self: Synchronized<A>) => Effect.Effect<never, never, A>;
export declare const updateSomeAndGet: <A>(f: (a: A) => Option.Option<A>) => (self: Synchronized<A>) => Effect.Effect<never, never, A>;
/**

@@ -167,3 +168,3 @@ * @macro traced

*/
export declare const updateSomeAndGetEffect: <A, R, E>(pf: (a: A) => import("@fp-ts/data/Option").Option<Effect.Effect<R, E, A>>) => (self: Synchronized<A>) => Effect.Effect<R, E, A>;
export declare const updateSomeAndGetEffect: <A, R, E>(pf: (a: A) => Option.Option<Effect.Effect<R, E, A>>) => (self: Synchronized<A>) => Effect.Effect<R, E, A>;
/**

@@ -170,0 +171,0 @@ * @since 1.0.0

17

Reloadable.d.ts

@@ -5,2 +5,5 @@ /**

import type * as Effect from "@effect/io/Effect";
import type * as Layer from "@effect/io/Layer";
import type * as Schedule from "@effect/io/Schedule";
import type * as Context from "@fp-ts/data/Context";
/**

@@ -47,3 +50,3 @@ * @since 1.0.0

*/
export declare const auto: <Out>(tag: import("@fp-ts/data/Context").Tag<Out>) => <In, E, R, Out2>(layer: import("./Layer").Layer<In, E, Out>, policy: import("./Schedule").Schedule<R, In, Out2>) => import("./Layer").Layer<In | R, E, Reloadable<Out>>;
export declare const auto: <Out>(tag: Context.Tag<Out>) => <In, E, R, Out2>(layer: Layer.Layer<In, E, Out>, policy: Schedule.Schedule<R, In, Out2>) => Layer.Layer<In | R, E, Reloadable<Out>>;
/**

@@ -57,3 +60,3 @@ * Makes a new reloadable service from a layer that describes the construction

*/
export declare const autoFromConfig: <Out>(tag: import("@fp-ts/data/Context").Tag<Out>) => <In, E, R, Out2>(layer: import("./Layer").Layer<In, E, Out>, scheduleFromConfig: (context: import("@fp-ts/data/Context").Context<In>) => import("./Schedule").Schedule<R, In, Out2>) => import("./Layer").Layer<In | R, E, Reloadable<Out>>;
export declare const autoFromConfig: <Out>(tag: Context.Tag<Out>) => <In, E, R, Out2>(layer: Layer.Layer<In, E, Out>, scheduleFromConfig: (context: Context.Context<In>) => Schedule.Schedule<R, In, Out2>) => Layer.Layer<In | R, E, Reloadable<Out>>;
/**

@@ -66,3 +69,3 @@ * Retrieves the current version of the reloadable service.

*/
export declare const get: <A>(tag: import("@fp-ts/data/Context").Tag<A>) => Effect.Effect<Reloadable<A>, never, A>;
export declare const get: <A>(tag: Context.Tag<A>) => Effect.Effect<Reloadable<A>, never, A>;
/**

@@ -75,3 +78,3 @@ * Makes a new reloadable service from a layer that describes the construction

*/
export declare const manual: <Out>(tag: import("@fp-ts/data/Context").Tag<Out>) => <In, E>(layer: import("./Layer").Layer<In, E, Out>) => import("./Layer").Layer<In, E, Reloadable<Out>>;
export declare const manual: <Out>(tag: Context.Tag<Out>) => <In, E>(layer: Layer.Layer<In, E, Out>) => Layer.Layer<In, E, Reloadable<Out>>;
/**

@@ -84,3 +87,3 @@ * Reloads the specified service.

*/
export declare const reload: <A>(tag: import("@fp-ts/data/Context").Tag<A>) => Effect.Effect<Reloadable<A>, unknown, void>;
export declare const reload: <A>(tag: Context.Tag<A>) => Effect.Effect<Reloadable<A>, unknown, void>;
/**

@@ -90,3 +93,3 @@ * @since 1.0.0

*/
export declare const reloadableTag: <A>(tag: import("@fp-ts/data/Context").Tag<A>) => import("@fp-ts/data/Context").Tag<Reloadable<A>>;
export declare const reloadableTag: <A>(tag: Context.Tag<A>) => Context.Tag<Reloadable<A>>;
/**

@@ -99,3 +102,3 @@ * Forks the reload of the service in the background, ignoring any errors.

*/
export declare const reloadFork: <A>(tag: import("@fp-ts/data/Context").Tag<A>) => Effect.Effect<Reloadable<A>, unknown, void>;
export declare const reloadFork: <A>(tag: Context.Tag<A>) => Effect.Effect<Reloadable<A>, unknown, void>;
//# sourceMappingURL=Reloadable.d.ts.map

7

Runtime.d.ts

@@ -8,2 +8,5 @@ /**

import type * as FiberId from "@effect/io/Fiber/Id";
import type * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags";
import type * as FiberRefs from "@effect/io/FiberRefs";
import type * as Context from "@fp-ts/data/Context";
/**

@@ -68,3 +71,3 @@ * @since 1.0.0

*/
export declare const defaultRuntimeFlags: import("./Fiber/Runtime/Flags").RuntimeFlags;
export declare const defaultRuntimeFlags: RuntimeFlags.RuntimeFlags;
/**

@@ -74,3 +77,3 @@ * @since 1.0.0

*/
export declare const make: <R>(context: import("@fp-ts/data/Context").Context<R>, runtimeFlags: import("./Fiber/Runtime/Flags").RuntimeFlags, fiberRefs: import("./FiberRefs").FiberRefs) => Runtime<R>;
export declare const make: <R>(context: Context.Context<R>, runtimeFlags: RuntimeFlags.RuntimeFlags, fiberRefs: FiberRefs.FiberRefs) => Runtime<R>;
//# sourceMappingURL=Runtime.d.ts.map

109

Schedule.d.ts

@@ -6,5 +6,12 @@ /**

import type * as Effect from "@effect/io/Effect";
import * as internal from "@effect/io/internal/schedule";
import type * as Random from "@effect/io/Random";
import type * as ScheduleDecision from "@effect/io/Schedule/Decision";
import type * as Interval from "@effect/io/Schedule/Interval";
import type * as Intervals from "@effect/io/Schedule/Intervals";
import type * as Chunk from "@fp-ts/data/Chunk";
import type * as Context from "@fp-ts/data/Context";
import type * as Duration from "@fp-ts/data/Duration";
import type * as Either from "@fp-ts/data/Either";
import type * as Option from "@fp-ts/data/Option";
import type { Predicate } from "@fp-ts/data/Predicate";
/**

@@ -121,3 +128,3 @@ * @since 1.0.0

*/
export declare const addDelay: <Out>(f: (out: Out) => import("@fp-ts/data/Duration").Duration) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const addDelay: <Out>(f: (out: Out) => Duration.Duration) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -130,3 +137,3 @@ * Returns a new schedule with the given effectfully computed delay added to

*/
export declare const addDelayEffect: <Out, Env2>(f: (out: Out) => Effect.Effect<Env2, never, import("@fp-ts/data/Duration").Duration>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
export declare const addDelayEffect: <Out, Env2>(f: (out: Out) => Effect.Effect<Env2, never, Duration.Duration>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
/**

@@ -146,3 +153,3 @@ * The same as `andThenEither`, but merges the output.

*/
export declare const andThenEither: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, import("@fp-ts/data/Either").Either<Out, Out2>>;
export declare const andThenEither: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, Either.Either<Out, Out2>>;
/**

@@ -195,3 +202,3 @@ * Returns a new schedule that maps this schedule to a constant output.

*/
export declare const choose: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, import("@fp-ts/data/Either").Either<In, In2>, import("@fp-ts/data/Either").Either<Out, Out2>>;
export declare const choose: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, Either.Either<In, In2>, Either.Either<Out, Out2>>;
/**

@@ -204,3 +211,3 @@ * Returns a new schedule that chooses between two schedules with a common

*/
export declare const chooseMerge: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, import("@fp-ts/data/Either").Either<In, In2>, Out2 | Out>;
export declare const chooseMerge: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, Either.Either<In, In2>, Out2 | Out>;
/**

@@ -212,3 +219,3 @@ * A schedule that recurs anywhere, collecting all inputs into a `Chunk`.

*/
export declare const collectAllInputs: <A>() => Schedule<never, A, import("@fp-ts/data/Chunk").Chunk<A>>;
export declare const collectAllInputs: <A>() => Schedule<never, A, Chunk.Chunk<A>>;
/**

@@ -220,3 +227,3 @@ * Returns a new schedule that collects the outputs of this one into a chunk.

*/
export declare const collectAllOutputs: <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, import("@fp-ts/data/Chunk").Chunk<Out>>;
export declare const collectAllOutputs: <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Chunk.Chunk<Out>>;
/**

@@ -229,3 +236,3 @@ * A schedule that recurs until the condition f fails, collecting all inputs

*/
export declare const collectUntil: <A>(f: import("@fp-ts/data/Predicate").Predicate<A>) => Schedule<never, A, import("@fp-ts/data/Chunk").Chunk<A>>;
export declare const collectUntil: <A>(f: Predicate<A>) => Schedule<never, A, Chunk.Chunk<A>>;
/**

@@ -238,3 +245,3 @@ * A schedule that recurs until the effectful condition f fails, collecting

*/
export declare const collectUntilEffect: <Env, A>(f: (a: A) => Effect.Effect<Env, never, boolean>) => Schedule<Env, A, import("@fp-ts/data/Chunk").Chunk<A>>;
export declare const collectUntilEffect: <Env, A>(f: (a: A) => Effect.Effect<Env, never, boolean>) => Schedule<Env, A, Chunk.Chunk<A>>;
/**

@@ -247,3 +254,3 @@ * A schedule that recurs as long as the condition f holds, collecting all

*/
export declare const collectWhile: <A>(f: import("@fp-ts/data/Predicate").Predicate<A>) => Schedule<never, A, import("@fp-ts/data/Chunk").Chunk<A>>;
export declare const collectWhile: <A>(f: Predicate<A>) => Schedule<never, A, Chunk.Chunk<A>>;
/**

@@ -257,3 +264,3 @@ * A schedule that recurs as long as the effectful condition holds, collecting

*/
export declare const collectWhileEffect: <Env, A>(f: (a: A) => Effect.Effect<Env, never, boolean>) => Schedule<Env, A, import("@fp-ts/data/Chunk").Chunk<A>>;
export declare const collectWhileEffect: <Env, A>(f: (a: A) => Effect.Effect<Env, never, boolean>) => Schedule<Env, A, Chunk.Chunk<A>>;
/**

@@ -322,3 +329,3 @@ * Returns the composition of this schedule and the specified schedule, by

*/
export declare const delayed: (f: (duration: import("@fp-ts/data/Duration").Duration) => import("@fp-ts/data/Duration").Duration) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const delayed: (f: (duration: Duration.Duration) => Duration.Duration) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -331,3 +338,3 @@ * Returns a new schedule with the specified effectfully computed delay added

*/
export declare const delayedEffect: <Env2>(f: (duration: import("@fp-ts/data/Duration").Duration) => Effect.Effect<Env2, never, import("@fp-ts/data/Duration").Duration>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
export declare const delayedEffect: <Env2>(f: (duration: Duration.Duration) => Effect.Effect<Env2, never, Duration.Duration>) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
/**

@@ -340,3 +347,3 @@ * Takes a schedule that produces a delay, and returns a new schedule that

*/
export declare const delayedSchedule: <Env, In>(schedule: Schedule<Env, In, import("@fp-ts/data/Duration").Duration>) => Schedule<Env, In, import("@fp-ts/data/Duration").Duration>;
export declare const delayedSchedule: <Env, In>(schedule: Schedule<Env, In, Duration.Duration>) => Schedule<Env, In, Duration.Duration>;
/**

@@ -348,3 +355,3 @@ * Returns a new schedule that outputs the delay between each occurence.

*/
export declare const delays: <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, import("@fp-ts/data/Duration").Duration>;
export declare const delays: <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Duration.Duration>;
/**

@@ -356,3 +363,3 @@ * Returns a new schedule that contramaps the input and maps the output.

*/
export declare const dimap: typeof internal.dimap;
export declare const dimap: <In, Out, In2, Out2>(f: (in2: In2) => In, g: (out: Out) => Out2) => <Env>(self: Schedule<Env, In, Out>) => Schedule<Env, In2, Out2>;
/**

@@ -381,3 +388,3 @@ * Returns a new schedule that contramaps the input and maps the output.

*/
export declare const duration: (duration: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const duration: (duration: Duration.Duration) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -405,3 +412,3 @@ * Returns a new schedule that performs a geometric union on the intervals

*/
export declare const elapsed: () => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const elapsed: () => Schedule<never, unknown, Duration.Duration>;
/**

@@ -426,3 +433,3 @@ * Returns a new schedule that will run the specified finalizer as soon as the

*/
export declare const exponential: (base: import("@fp-ts/data/Duration").Duration, factor?: number) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const exponential: (base: Duration.Duration, factor?: number) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -436,3 +443,3 @@ * A schedule that always recurs, increasing delays by summing the preceding

*/
export declare const fibonacci: (one: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const fibonacci: (one: Duration.Duration) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -453,3 +460,3 @@ * A schedule that recurs on a fixed interval. Returns the number of

*/
export declare const fixed: (interval: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, number>;
export declare const fixed: (interval: Duration.Duration) => Schedule<never, unknown, number>;
/**

@@ -482,3 +489,3 @@ * Returns a new schedule that folds over the outputs of this one.

*/
export declare const fromDelay: (delay: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const fromDelay: (delay: Duration.Duration) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -492,3 +499,3 @@ * A schedule that recurs once for each of the specified durations, delaying

*/
export declare const fromDelays: (delay: import("@fp-ts/data/Duration").Duration, ...delays: import("@fp-ts/data/Duration").Duration[]) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const fromDelays: (delay: Duration.Duration, ...delays: Array<Duration.Duration>) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -535,3 +542,3 @@ * A schedule that always recurs, mapping input values through the specified

*/
export declare const intersectWith: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>, f: (x: import("./Schedule/Intervals").Intervals, y: import("./Schedule/Intervals").Intervals) => import("./Schedule/Intervals").Intervals) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, readonly [Out, Out2]>;
export declare const intersectWith: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>, f: (x: Intervals.Intervals, y: Intervals.Intervals) => Intervals.Intervals) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, readonly [Out, Out2]>;
/**

@@ -547,3 +554,3 @@ * Returns a new schedule that randomly modifies the size of the intervals of

*/
export declare const jittered: (min?: number, max?: number) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<import("./Random").Random | Env, In, Out>;
export declare const jittered: (min?: number, max?: number) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env | Random.Random, In, Out>;
/**

@@ -557,3 +564,3 @@ * Returns a new schedule that makes this schedule available on the `Left`

*/
export declare const left: <Env, In, Out, X>(self: Schedule<Env, In, Out>) => Schedule<Env, import("@fp-ts/data/Either").Either<In, X>, import("@fp-ts/data/Either").Either<Out, X>>;
export declare const left: <Env, In, Out, X>(self: Schedule<Env, In, Out>) => Schedule<Env, Either.Either<In, X>, Either.Either<Out, X>>;
/**

@@ -567,3 +574,3 @@ * A schedule that always recurs, but will repeat on a linear time interval,

*/
export declare const linear: (base: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const linear: (base: Duration.Duration) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -603,3 +610,3 @@ * Returns a new schedule that maps the output of this schedule through the

*/
export declare const modifyDelay: <Out>(f: (out: Out, duration: import("@fp-ts/data/Duration").Duration) => import("@fp-ts/data/Duration").Duration) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const modifyDelay: <Out>(f: (out: Out, duration: Duration.Duration) => Duration.Duration) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -612,3 +619,3 @@ * Returns a new schedule that modifies the delay using the specified

*/
export declare const modifyDelayEffect: <Out, Env2>(f: (out: Out, duration: import("@fp-ts/data/Duration").Duration) => Effect.Effect<Env2, never, import("@fp-ts/data/Duration").Duration>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
export declare const modifyDelayEffect: <Out, Env2>(f: (out: Out, duration: Duration.Duration) => Effect.Effect<Env2, never, Duration.Duration>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>;
/**

@@ -644,3 +651,3 @@ * Returns a new schedule that applies the current one but runs the specified

*/
export declare const provideEnvironment: <R>(context: import("@fp-ts/data/Context").Context<R>) => <In, Out>(self: Schedule<R, In, Out>) => Schedule<never, In, Out>;
export declare const provideEnvironment: <R>(context: Context.Context<R>) => <In, Out>(self: Schedule<R, In, Out>) => Schedule<never, In, Out>;
/**

@@ -654,3 +661,3 @@ * Returns a new schedule with the single service it requires provided to it.

*/
export declare const provideService: <T, T1 extends T>(tag: import("@fp-ts/data/Context").Tag<T>, service: T1) => <R, In, Out>(self: Schedule<T | R, In, Out>) => Schedule<Exclude<R, T>, In, Out>;
export declare const provideService: <T, T1 extends T>(tag: Context.Tag<T>, service: T1) => <R, In, Out>(self: Schedule<T | R, In, Out>) => Schedule<Exclude<R, T>, In, Out>;
/**

@@ -663,3 +670,3 @@ * Transforms the environment being provided to this schedule with the

*/
export declare const provideSomeEnvironment: <R0, R>(f: (env0: import("@fp-ts/data/Context").Context<R0>) => import("@fp-ts/data/Context").Context<R>) => <In, Out>(self: Schedule<R, In, Out>) => Schedule<R0, In, Out>;
export declare const provideSomeEnvironment: <R0, R>(f: (env0: Context.Context<R0>) => Context.Context<R>) => <In, Out>(self: Schedule<R, In, Out>) => Schedule<R0, In, Out>;
/**

@@ -673,3 +680,3 @@ * Returns a new schedule that reconsiders every decision made by this

*/
export declare const reconsider: <Out, Out2>(f: (out: Out, decision: ScheduleDecision.ScheduleDecision) => import("@fp-ts/data/Either").Either<Out2, readonly [Out2, import("./Schedule/Interval").Interval]>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out2>;
export declare const reconsider: <Out, Out2>(f: (out: Out, decision: ScheduleDecision.ScheduleDecision) => Either.Either<Out2, readonly [Out2, Interval.Interval]>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out2>;
/**

@@ -683,3 +690,3 @@ * Returns a new schedule that effectfully reconsiders every decision made by

*/
export declare const reconsiderEffect: <Out, Env2, Out2>(f: (out: Out, decision: ScheduleDecision.ScheduleDecision) => Effect.Effect<Env2, never, import("@fp-ts/data/Either").Either<Out2, readonly [Out2, import("./Schedule/Interval").Interval]>>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out2>;
export declare const reconsiderEffect: <Out, Env2, Out2>(f: (out: Out, decision: ScheduleDecision.ScheduleDecision) => Effect.Effect<Env2, never, Either.Either<Out2, readonly [Out2, Interval.Interval]>>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out2>;
/**

@@ -691,3 +698,3 @@ * A schedule that recurs for until the predicate evaluates to true.

*/
export declare const recurUntil: <A>(f: import("@fp-ts/data/Predicate").Predicate<A>) => Schedule<never, A, A>;
export declare const recurUntil: <A>(f: Predicate<A>) => Schedule<never, A, A>;
/**

@@ -721,3 +728,3 @@ * A schedule that recurs for until the predicate evaluates to true.

*/
export declare const recurUpTo: (duration: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, import("@fp-ts/data/Duration").Duration>;
export declare const recurUpTo: (duration: Duration.Duration) => Schedule<never, unknown, Duration.Duration>;
/**

@@ -729,3 +736,3 @@ * A schedule that recurs for as long as the predicate evaluates to true.

*/
export declare const recurWhile: <A>(f: import("@fp-ts/data/Predicate").Predicate<A>) => Schedule<never, A, A>;
export declare const recurWhile: <A>(f: Predicate<A>) => Schedule<never, A, A>;
/**

@@ -778,3 +785,3 @@ * A schedule that recurs for as long as the effectful predicate evaluates to

*/
export declare const resetAfter: (duration: import("@fp-ts/data/Duration").Duration) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const resetAfter: (duration: Duration.Duration) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -787,3 +794,3 @@ * Resets the schedule when the specified predicate on the schedule output

*/
export declare const resetWhen: <Out>(f: import("@fp-ts/data/Predicate").Predicate<Out>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const resetWhen: <Out>(f: Predicate<Out>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -797,3 +804,3 @@ * Returns a new schedule that makes this schedule available on the `Right`

*/
export declare const right: <Env, In, Out, X>(self: Schedule<Env, In, Out>) => Schedule<Env, import("@fp-ts/data/Either").Either<X, In>, import("@fp-ts/data/Either").Either<X, Out>>;
export declare const right: <Env, In, Out, X>(self: Schedule<Env, In, Out>) => Schedule<Env, Either.Either<X, In>, Either.Either<X, Out>>;
/**

@@ -805,3 +812,3 @@ * Runs a schedule using the provided inputs, and collects all outputs.

*/
export declare const run: <In>(now: number, input: Iterable<In>) => <Env, Out>(self: Schedule<Env, In, Out>) => Effect.Effect<Env, never, import("@fp-ts/data/Chunk").Chunk<Out>>;
export declare const run: <In>(now: number, input: Iterable<In>) => <Env, Out>(self: Schedule<Env, In, Out>) => Effect.Effect<Env, never, Chunk.Chunk<Out>>;
/**

@@ -825,3 +832,3 @@ * Cron-like schedule that recurs every specified `second` of each minute. It

*/
export declare const spaced: (duration: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, number>;
export declare const spaced: (duration: Duration.Duration) => Schedule<never, unknown, number>;
/**

@@ -891,3 +898,3 @@ * A schedule that does not recur, it just stops.

*/
export declare const unionWith: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>, f: (x: import("./Schedule/Intervals").Intervals, y: import("./Schedule/Intervals").Intervals) => import("./Schedule/Intervals").Intervals) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, readonly [Out, Out2]>;
export declare const unionWith: <Env2, In2, Out2>(that: Schedule<Env2, In2, Out2>, f: (x: Intervals.Intervals, y: Intervals.Intervals) => Intervals.Intervals) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, readonly [Out, Out2]>;
/**

@@ -900,3 +907,3 @@ * Returns a new schedule that continues until the specified predicate on the

*/
export declare const untilInput: <In>(f: import("@fp-ts/data/Predicate").Predicate<In>) => <Env, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const untilInput: <In>(f: Predicate<In>) => <Env, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -917,3 +924,3 @@ * Returns a new schedule that continues until the specified effectful

*/
export declare const untilOutput: <Out>(f: import("@fp-ts/data/Predicate").Predicate<Out>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const untilOutput: <Out>(f: Predicate<Out>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -933,3 +940,3 @@ * Returns a new schedule that continues until the specified effectful

*/
export declare const upTo: (duration: import("@fp-ts/data/Duration").Duration) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const upTo: (duration: Duration.Duration) => <Env, In, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -942,3 +949,3 @@ * Returns a new schedule that continues for as long the specified predicate

*/
export declare const whileInput: <In>(f: import("@fp-ts/data/Predicate").Predicate<In>) => <Env, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const whileInput: <In>(f: Predicate<In>) => <Env, Out>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -959,3 +966,3 @@ * Returns a new schedule that continues for as long the specified effectful

*/
export declare const whileOutput: <Out>(f: import("@fp-ts/data/Predicate").Predicate<Out>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
export declare const whileOutput: <Out>(f: Predicate<Out>) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env, In, Out>;
/**

@@ -985,3 +992,3 @@ * Returns a new schedule that continues for as long the specified effectful

*/
export declare const windowed: (interval: import("@fp-ts/data/Duration").Duration) => Schedule<never, unknown, number>;
export declare const windowed: (interval: Duration.Duration) => Schedule<never, unknown, number>;
/**

@@ -1007,3 +1014,3 @@ * The same as `intersect` but ignores the right output.

*/
export declare const zipWith: typeof internal.zipWith;
export declare const zipWith: <Env2, In2, Out2, Out, Out3>(that: Schedule<Env2, In2, Out2>, f: (out: Out, out2: Out2) => Out3) => <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In & In2, Out3>;
//# sourceMappingURL=Schedule.d.ts.map

3

Schedule/Decision.d.ts

@@ -5,2 +5,3 @@ /**

import * as internal from "@effect/io/internal/schedule/decision";
import type * as Interval from "@effect/io/Schedule/Interval";
import type * as Intervals from "@effect/io/Schedule/Intervals";

@@ -38,3 +39,3 @@ /**

*/
export declare const continueWith: (interval: import("./Interval").Interval) => ScheduleDecision;
export declare const continueWith: (interval: Interval.Interval) => ScheduleDecision;
/**

@@ -41,0 +42,0 @@ * @since 1.0.0

6

Schedule/Interval.d.ts

@@ -0,1 +1,3 @@

import type * as Duration from "@fp-ts/data/Duration";
import type * as Option from "@fp-ts/data/Option";
/**

@@ -91,3 +93,3 @@ * @since 1.0.0

*/
export declare const size: (self: Interval) => import("@fp-ts/data/Duration").Duration;
export declare const size: (self: Interval) => Duration.Duration;
/**

@@ -101,3 +103,3 @@ * Computes a new `Interval` which is the union of this `Interval` and that

*/
export declare const union: (that: Interval) => (self: Interval) => import("@fp-ts/data/Option").Option<Interval>;
export declare const union: (that: Interval) => (self: Interval) => Option.Option<Interval>;
/**

@@ -104,0 +106,0 @@ * Construct an `Interval` that includes all time equal to and after the

6

Scope.d.ts

@@ -5,3 +5,3 @@ /**

import type * as Effect from "@effect/io/Effect";
import type { ExecutionStrategy } from "@effect/io/ExecutionStrategy";
import type * as ExecutionStrategy from "@effect/io/ExecutionStrategy";
import type * as Exit from "@effect/io/Exit";

@@ -109,3 +109,3 @@ import type * as Context from "@fp-ts/data/Context";

*/
export declare const fork: (strategy: ExecutionStrategy) => (self: Scope) => Effect.Effect<never, never, CloseableScope>;
export declare const fork: (strategy: ExecutionStrategy.ExecutionStrategy) => (self: Scope) => Effect.Effect<never, never, CloseableScope>;
/**

@@ -131,3 +131,3 @@ * Uses the scope by providing it to an `Effect` workflow that needs a scope,

*/
export declare const make: (executionStrategy?: ExecutionStrategy | undefined) => Effect.Effect<never, never, CloseableScope>;
export declare const make: (executionStrategy?: ExecutionStrategy.ExecutionStrategy | undefined) => Effect.Effect<never, never, CloseableScope>;
//# sourceMappingURL=Scope.d.ts.map

12

ScopedRef.d.ts

@@ -0,1 +1,5 @@

/**
* @since 1.0.0
*/
import type * as Effect from "@effect/io/Effect";
import type * as Scope from "@effect/io/Scope";

@@ -46,3 +50,3 @@ /**

*/
export declare const fromAcquire: <R, E, A>(acquire: import("./Effect").Effect<R, E, A>) => import("./Effect").Effect<Scope.Scope | R, E, ScopedRef<A>>;
export declare const fromAcquire: <R, E, A>(acquire: Effect.Effect<R, E, A>) => Effect.Effect<Scope.Scope | R, E, ScopedRef<A>>;
/**

@@ -55,3 +59,3 @@ * Retrieves the current value of the scoped reference.

*/
export declare const get: <A>(self: ScopedRef<A>) => import("./Effect").Effect<never, never, A>;
export declare const get: <A>(self: ScopedRef<A>) => Effect.Effect<never, never, A>;
/**

@@ -65,3 +69,3 @@ * Creates a new `ScopedRef` from the specified value. This method should

*/
export declare const make: <A>(evaluate: () => A) => import("./Effect").Effect<Scope.Scope, never, ScopedRef<A>>;
export declare const make: <A>(evaluate: () => A) => Effect.Effect<Scope.Scope, never, ScopedRef<A>>;
/**

@@ -79,3 +83,3 @@ * Sets the value of this reference to the specified resourcefully-created

*/
export declare const set: <R, E, A>(acquire: import("./Effect").Effect<Scope.Scope | R, E, A>) => (self: ScopedRef<A>) => import("./Effect").Effect<R, E, void>;
export declare const set: <R, E, A>(acquire: Effect.Effect<Scope.Scope | R, E, A>) => (self: ScopedRef<A>) => Effect.Effect<R, E, void>;
//# sourceMappingURL=ScopedRef.d.ts.map

4

ScopedRef.js

@@ -12,6 +12,2 @@ "use strict";

* @since 1.0.0
*/
/**
* @since 1.0.0
* @category symbols

@@ -18,0 +14,0 @@ */

21

Supervisor.d.ts

@@ -10,4 +10,8 @@ /**

import type * as Fiber from "@effect/io/Fiber";
import type * as Layer from "@effect/io/Layer";
import type * as Chunk from "@fp-ts/data/Chunk";
import type * as Context from "@fp-ts/data/Context";
import type * as MutableRef from "@fp-ts/data/mutable/MutableRef";
import type * as Option from "@fp-ts/data/Option";
import type * as SortedSet from "@fp-ts/data/SortedSet";
/**

@@ -82,8 +86,6 @@ * @since 1.0.0

/**
* Unsafely creates a new supervisor that tracks children in a set.
*
* @since 1.0.0
* @category unsafe
* @category environment
*/
export declare const unsafeTrack: () => Supervisor<import("@fp-ts/data/Chunk").Chunk<Fiber.RuntimeFiber<any, any>>>;
export declare const addSupervisor: <A>(supervisor: Supervisor<A>) => Layer.Layer<never, never, never>;
/**

@@ -96,3 +98,3 @@ * Creates a new supervisor that tracks children in a set.

*/
export declare const track: () => Effect.Effect<never, never, Supervisor<import("@fp-ts/data/Chunk").Chunk<Fiber.RuntimeFiber<any, any>>>>;
export declare const fibersIn: (ref: MutableRef.MutableRef<SortedSet.SortedSet<Fiber.RuntimeFiber<any, any>>>) => Effect.Effect<never, never, Supervisor<SortedSet.SortedSet<Fiber.RuntimeFiber<any, any>>>>;
/**

@@ -119,3 +121,10 @@ * Creates a new supervisor that constantly yields effect when polled

*/
export declare const fibersIn: (ref: import("@fp-ts/data/mutable/MutableRef").MutableRef<import("@fp-ts/data/SortedSet").SortedSet<Fiber.RuntimeFiber<any, any>>>) => Effect.Effect<never, never, Supervisor<import("@fp-ts/data/SortedSet").SortedSet<Fiber.RuntimeFiber<any, any>>>>;
export declare const track: () => Effect.Effect<never, never, Supervisor<Chunk.Chunk<Fiber.RuntimeFiber<any, any>>>>;
/**
* Unsafely creates a new supervisor that tracks children in a set.
*
* @since 1.0.0
* @category unsafe
*/
export declare const unsafeTrack: () => Supervisor<Chunk.Chunk<Fiber.RuntimeFiber<any, any>>>;
//# sourceMappingURL=Supervisor.d.ts.map

27

Supervisor.js

@@ -6,3 +6,4 @@ "use strict";

});
exports.unsafeTrack = exports.track = exports.none = exports.fromEffect = exports.fibersIn = exports.SupervisorTypeId = void 0;
exports.unsafeTrack = exports.track = exports.none = exports.fromEffect = exports.fibersIn = exports.addSupervisor = exports.SupervisorTypeId = void 0;
var circular = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/layer/circular"));
var internal = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/supervisor"));

@@ -17,9 +18,7 @@ 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); }

/**
* Unsafely creates a new supervisor that tracks children in a set.
*
* @since 1.0.0
* @category unsafe
* @category environment
*/
exports.SupervisorTypeId = SupervisorTypeId;
const unsafeTrack = internal.unsafeTrack;
const addSupervisor = circular.addSupervisor;
/**

@@ -32,4 +31,4 @@ * Creates a new supervisor that tracks children in a set.

*/
exports.unsafeTrack = unsafeTrack;
const track = internal.track;
exports.addSupervisor = addSupervisor;
const fibersIn = internal.fibersIn;
/**

@@ -41,3 +40,3 @@ * Creates a new supervisor that constantly yields effect when polled

*/
exports.track = track;
exports.fibersIn = fibersIn;
const fromEffect = internal.fromEffect;

@@ -60,4 +59,12 @@ /**

exports.none = none;
const fibersIn = internal.fibersIn;
exports.fibersIn = fibersIn;
const track = internal.track;
/**
* Unsafely creates a new supervisor that tracks children in a set.
*
* @since 1.0.0
* @category unsafe
*/
exports.track = track;
const unsafeTrack = internal.unsafeTrack;
exports.unsafeTrack = unsafeTrack;
//# sourceMappingURL=Supervisor.js.map

4

Tracer.d.ts

@@ -5,3 +5,3 @@ /**

import type { Effect } from "@effect/io/Effect";
import type { Option } from "@fp-ts/data/Option";
import * as Option from "@fp-ts/data/Option";
/**

@@ -38,3 +38,3 @@ * @category symbols

*/
export declare const currentTracer: import("./FiberRef").FiberRef<Option<Tracer>>;
export declare const currentTracer: import("./FiberRef").FiberRef<Option.Option<Tracer>>;
//# sourceMappingURL=Tracer.d.ts.map

4

Tracer.js

@@ -8,3 +8,3 @@ "use strict";

var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));
var _Option = /*#__PURE__*/require("@fp-ts/data/Option");
var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/Option"));
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); }

@@ -31,4 +31,4 @@ 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; }

exports.make = make;
const currentTracer = /*#__PURE__*/core.fiberRefUnsafeMake(_Option.none);
const currentTracer = /*#__PURE__*/core.fiberRefUnsafeMake(Option.none);
exports.currentTracer = currentTracer;
//# sourceMappingURL=Tracer.js.map
_mjs/Cause.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Clock.mjs

Sorry, the diff of this file is not supported yet

_mjs/Clock.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Debug.mjs

Sorry, the diff of this file is not supported yet

_mjs/Debug.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/DefaultServices.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Deferred.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Effect.mjs

Sorry, the diff of this file is not supported yet

_mjs/Effect.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/ExecutionStrategy.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Exit.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Fiber.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Fiber/Runtime/Flags.mjs

Sorry, the diff of this file is not supported yet

_mjs/Fiber/Runtime/Flags.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/FiberRef.mjs

Sorry, the diff of this file is not supported yet

_mjs/FiberRef.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/FiberRefs.mjs

Sorry, the diff of this file is not supported yet

_mjs/FiberRefs.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/FiberRefs/Patch.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Hub.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/cause.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/cause.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/core.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/core.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/effect.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/effect.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/effect/circular.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/effect/circular.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/fiber.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/fiber.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/fiberRefs.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/fiberRefs.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/fiberRuntime.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/fiberRuntime.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/fiberScope.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/fiberScope.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/hub.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/hub.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/layer/circular.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/layer/circular.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/logger.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/logger.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/runtime.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/runtime.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/schedule.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/schedule.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/internal/supervisor/patch.mjs

Sorry, the diff of this file is not supported yet

_mjs/internal/supervisor/patch.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Layer.mjs

Sorry, the diff of this file is not supported yet

_mjs/Layer.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Logger.mjs

Sorry, the diff of this file is not supported yet

_mjs/Logger.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Logger/Level.mjs

Sorry, the diff of this file is not supported yet

_mjs/Logger/Level.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Logger/Span.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Boundaries.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Hook.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Key.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/KeyType.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Label.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Pair.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Polling.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/Registry.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Metric/State.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Queue.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Random.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Ref.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Ref/Synchronized.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Reloadable.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Runtime.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Schedule.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Schedule/Decision.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Schedule/Interval.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Schedule/Intervals.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Scope.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/ScopedRef.mjs

Sorry, the diff of this file is not supported yet

_mjs/ScopedRef.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Supervisor.mjs

Sorry, the diff of this file is not supported yet

_mjs/Supervisor.mjs.map

Sorry, the diff of this file is not supported yet

_mjs/Tracer.mjs

Sorry, the diff of this file is not supported yet

_mjs/Tracer.mjs.map

Sorry, the diff of this file is not supported yet

Cause.d.ts.map

Sorry, the diff of this file is not supported yet

Cause.js.map

Sorry, the diff of this file is not supported yet

Clock.d.ts.map

Sorry, the diff of this file is not supported yet

Clock.js.map

Sorry, the diff of this file is not supported yet

Debug.d.ts.map

Sorry, the diff of this file is not supported yet

Debug.js.map

Sorry, the diff of this file is not supported yet

DefaultServices.d.ts.map

Sorry, the diff of this file is not supported yet

DefaultServices.js.map

Sorry, the diff of this file is not supported yet

Deferred.d.ts.map

Sorry, the diff of this file is not supported yet

Deferred.js.map

Sorry, the diff of this file is not supported yet

Effect.d.ts

Sorry, the diff of this file is too big to display

Effect.d.ts.map

Sorry, the diff of this file is not supported yet

Effect.js

Sorry, the diff of this file is too big to display

Effect.js.map

Sorry, the diff of this file is not supported yet

ExecutionStrategy.d.ts.map

Sorry, the diff of this file is not supported yet

ExecutionStrategy.js.map

Sorry, the diff of this file is not supported yet

Exit.d.ts.map

Sorry, the diff of this file is not supported yet

Exit.js.map

Sorry, the diff of this file is not supported yet

Fiber.d.ts.map

Sorry, the diff of this file is not supported yet

Fiber.js.map

Sorry, the diff of this file is not supported yet

Fiber/Runtime/Flags.d.ts.map

Sorry, the diff of this file is not supported yet

Fiber/Runtime/Flags.js.map

Sorry, the diff of this file is not supported yet

FiberRef.d.ts.map

Sorry, the diff of this file is not supported yet

FiberRef.js.map

Sorry, the diff of this file is not supported yet

FiberRefs.d.ts.map

Sorry, the diff of this file is not supported yet

FiberRefs.js.map

Sorry, the diff of this file is not supported yet

FiberRefs/Patch.d.ts.map

Sorry, the diff of this file is not supported yet

FiberRefs/Patch.js.map

Sorry, the diff of this file is not supported yet

Hub.d.ts.map

Sorry, the diff of this file is not supported yet

Hub.js.map

Sorry, the diff of this file is not supported yet

internal/cause.js.map

Sorry, the diff of this file is not supported yet

internal/core.d.ts.map

Sorry, the diff of this file is not supported yet

internal/core.js.map

Sorry, the diff of this file is not supported yet

internal/effect.d.ts.map

Sorry, the diff of this file is not supported yet

internal/effect.js

Sorry, the diff of this file is too big to display

internal/effect.js.map

Sorry, the diff of this file is not supported yet

internal/effect/circular.d.ts.map

Sorry, the diff of this file is not supported yet

internal/effect/circular.js.map

Sorry, the diff of this file is not supported yet

internal/fiber.js.map

Sorry, the diff of this file is not supported yet

internal/fiberRefs.d.ts.map

Sorry, the diff of this file is not supported yet

internal/fiberRefs.js.map

Sorry, the diff of this file is not supported yet

internal/fiberRuntime.d.ts.map

Sorry, the diff of this file is not supported yet

internal/fiberRuntime.js

Sorry, the diff of this file is too big to display

internal/fiberRuntime.js.map

Sorry, the diff of this file is not supported yet

internal/fiberScope.d.ts.map

Sorry, the diff of this file is not supported yet

internal/fiberScope.js.map

Sorry, the diff of this file is not supported yet

internal/hub.js.map

Sorry, the diff of this file is not supported yet

internal/layer/circular.js.map

Sorry, the diff of this file is not supported yet

internal/logger.js.map

Sorry, the diff of this file is not supported yet

internal/runtime.js.map

Sorry, the diff of this file is not supported yet

internal/schedule.js.map

Sorry, the diff of this file is not supported yet

internal/supervisor/patch.js.map

Sorry, the diff of this file is not supported yet

Layer.d.ts.map

Sorry, the diff of this file is not supported yet

Layer.js.map

Sorry, the diff of this file is not supported yet

Logger.d.ts.map

Sorry, the diff of this file is not supported yet

Logger.js.map

Sorry, the diff of this file is not supported yet

Logger/Level.d.ts.map

Sorry, the diff of this file is not supported yet

Logger/Level.js.map

Sorry, the diff of this file is not supported yet

Logger/Span.d.ts.map

Sorry, the diff of this file is not supported yet

Logger/Span.js.map

Sorry, the diff of this file is not supported yet

Metric.d.ts.map

Sorry, the diff of this file is not supported yet

Metric.js.map

Sorry, the diff of this file is not supported yet

Metric/Boundaries.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Boundaries.js.map

Sorry, the diff of this file is not supported yet

Metric/Hook.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Hook.js.map

Sorry, the diff of this file is not supported yet

Metric/Key.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Key.js.map

Sorry, the diff of this file is not supported yet

Metric/KeyType.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/KeyType.js.map

Sorry, the diff of this file is not supported yet

Metric/Label.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Label.js.map

Sorry, the diff of this file is not supported yet

Metric/Pair.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Pair.js.map

Sorry, the diff of this file is not supported yet

Metric/Polling.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Polling.js.map

Sorry, the diff of this file is not supported yet

Metric/Registry.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/Registry.js.map

Sorry, the diff of this file is not supported yet

Metric/State.d.ts.map

Sorry, the diff of this file is not supported yet

Metric/State.js.map

Sorry, the diff of this file is not supported yet

Queue.d.ts.map

Sorry, the diff of this file is not supported yet

Queue.js.map

Sorry, the diff of this file is not supported yet

Random.d.ts.map

Sorry, the diff of this file is not supported yet

Random.js.map

Sorry, the diff of this file is not supported yet

Ref.d.ts.map

Sorry, the diff of this file is not supported yet

Ref.js.map

Sorry, the diff of this file is not supported yet

Ref/Synchronized.d.ts.map

Sorry, the diff of this file is not supported yet

Ref/Synchronized.js.map

Sorry, the diff of this file is not supported yet

Reloadable.d.ts.map

Sorry, the diff of this file is not supported yet

Reloadable.js.map

Sorry, the diff of this file is not supported yet

Runtime.d.ts.map

Sorry, the diff of this file is not supported yet

Runtime.js.map

Sorry, the diff of this file is not supported yet

Schedule.d.ts.map

Sorry, the diff of this file is not supported yet

Schedule.js.map

Sorry, the diff of this file is not supported yet

Schedule/Decision.d.ts.map

Sorry, the diff of this file is not supported yet

Schedule/Decision.js.map

Sorry, the diff of this file is not supported yet

Schedule/Interval.d.ts.map

Sorry, the diff of this file is not supported yet

Schedule/Interval.js.map

Sorry, the diff of this file is not supported yet

Schedule/Intervals.d.ts.map

Sorry, the diff of this file is not supported yet

Schedule/Intervals.js.map

Sorry, the diff of this file is not supported yet

Scope.d.ts.map

Sorry, the diff of this file is not supported yet

Scope.js.map

Sorry, the diff of this file is not supported yet

ScopedRef.d.ts.map

Sorry, the diff of this file is not supported yet

ScopedRef.js.map

Sorry, the diff of this file is not supported yet

Supervisor.d.ts.map

Sorry, the diff of this file is not supported yet

Supervisor.js.map

Sorry, the diff of this file is not supported yet

Tracer.d.ts.map

Sorry, the diff of this file is not supported yet

Tracer.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc