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.31.2 to 0.31.3

17

Cause.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type { Predicate } from "@effect/data/Predicate";

@@ -114,3 +115,3 @@ import type * as FiberId from "@effect/io/Fiber/Id";

*/
export type Cause<E> = Empty | Fail<E> | Die | Interrupt | Annotated<E> | Sequential<E> | Parallel<E>;
export type Cause<E> = (Empty | Fail<E> | Die | Interrupt | Annotated<E> | Sequential<E> | Parallel<E>) & Pipeable<Cause<E>>;
/**

@@ -215,3 +216,3 @@ * @since 1.0.0

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

@@ -226,3 +227,3 @@ }

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

@@ -239,3 +240,3 @@ readonly error: E;

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

@@ -251,3 +252,3 @@ readonly defect: unknown;

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

@@ -265,3 +266,3 @@ readonly fiberId: FiberId.FiberId;

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

@@ -284,3 +285,3 @@ readonly cause: Cause<E>;

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

@@ -302,3 +303,3 @@ readonly left: Cause<E>;

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

@@ -305,0 +306,0 @@ readonly left: Cause<E>;

3

Config.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type { Predicate, Refinement } from "@effect/data/Predicate";

@@ -41,3 +42,3 @@ import type * as ConfigError from "@effect/io/Config/Error";

*/
export interface Config<A> extends Config.Variance<A> {
export interface Config<A> extends Config.Variance<A>, Pipeable<Config<A>> {
}

@@ -44,0 +45,0 @@ /**

3

Config/Provider.d.ts

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

import type * as HashSet from "@effect/data/HashSet";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Config from "@effect/io/Config";

@@ -39,3 +40,3 @@ import type * as ConfigError from "@effect/io/Config/Error";

*/
export interface ConfigProvider extends ConfigProvider.Proto {
export interface ConfigProvider extends ConfigProvider.Proto, Pipeable<ConfigProvider> {
/**

@@ -42,0 +43,0 @@ * Loads the specified configuration, or fails with a config error.

3

Deferred.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Cause from "@effect/io/Cause";

@@ -33,3 +34,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface Deferred<E, A> extends Deferred.Variance<E, A> {
export interface Deferred<E, A> extends Deferred.Variance<E, A>, Pipeable<Deferred<E, A>> {
}

@@ -36,0 +37,0 @@ /**

7

Exit.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable, PipeableOverride } from "@effect/data/Pipeable";
import type { Predicate } from "@effect/data/Predicate";

@@ -22,3 +23,3 @@ import type * as Unify from "@effect/data/Unify";

*/
export type Exit<E, A> = Failure<E, A> | Success<E, A>;
export type Exit<E, A> = (Failure<E, A> | Success<E, A>) & Pipeable<Exit<E, A>>;
/**

@@ -31,3 +32,3 @@ * Represents a failed `Effect` workflow containing the `Cause` of the failure

*/
export interface Failure<E, A> extends Effect.Effect<never, E, A> {
export interface Failure<E, A> extends PipeableOverride<Effect.Effect<never, E, A>, Failure<E, A>> {
readonly _tag: "Failure";

@@ -62,3 +63,3 @@ readonly cause: Cause.Cause<E>;

*/
export interface Success<E, A> extends Effect.Effect<never, E, A> {
export interface Success<E, A> extends PipeableOverride<Effect.Effect<never, E, A>, Success<E, A>> {
readonly _tag: "Success";

@@ -65,0 +66,0 @@ readonly value: A;

3

Fiber.d.ts

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

import type * as order from "@effect/data/Order";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Cause from "@effect/io/Cause";

@@ -49,3 +50,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface Fiber<E, A> extends Fiber.Variance<E, A> {
export interface Fiber<E, A> extends Fiber.Variance<E, A>, Pipeable<Fiber<E, A>> {
/**

@@ -52,0 +53,0 @@ * The identity of the fiber.

3

FiberRef.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Cause from "@effect/io/Cause";

@@ -38,3 +39,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface FiberRef<A> extends Variance<A> {
export interface FiberRef<A> extends Variance<A>, Pipeable<FiberRef<A>> {
}

@@ -41,0 +42,0 @@ /**

3

FiberRefs.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Arr from "@effect/data/ReadonlyArray";

@@ -30,3 +31,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface FiberRefs {
export interface FiberRefs extends Pipeable<FiberRefs> {
readonly [FiberRefsSym]: FiberRefsSym;

@@ -33,0 +34,0 @@ readonly locals: Map<FiberRef.FiberRef<any>, Arr.NonEmptyReadonlyArray<readonly [FiberId.Runtime, any]>>;

3

Hub.d.ts
/**
* @since 1.0.0
*/
import type { PipeableOverride } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -15,3 +16,3 @@ import type * as Queue from "@effect/io/Queue";

*/
export interface Hub<A> extends Queue.Enqueue<A> {
export interface Hub<A> extends PipeableOverride<Queue.Enqueue<A>, Hub<A>> {
/**

@@ -18,0 +19,0 @@ * Publishes a message to the hub, returning whether the message was published

4

internal/cause.js

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

var MRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/MutableRef"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
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); }

@@ -41,2 +42,5 @@ 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; }

return isCause(that) && causeEquals(this, that);
},
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}

@@ -43,0 +47,0 @@ };

6

internal/config.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var ConfigError = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Config/Error"));

@@ -31,3 +32,6 @@ var configError = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/configError"));

const proto = {
[ConfigTypeId]: configVariance
[ConfigTypeId]: configVariance,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -34,0 +38,0 @@ /** @internal */

4

internal/configProvider.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var RA = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));

@@ -41,2 +42,5 @@ var _config = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/config"));

[ConfigProviderTypeId]: ConfigProviderTypeId,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
...options

@@ -43,0 +47,0 @@ });

53

internal/core.js

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

label: "ALL",
ordinal: Number.MIN_SAFE_INTEGER
ordinal: Number.MIN_SAFE_INTEGER,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -707,3 +710,6 @@ /** @internal */

label: "FATAL",
ordinal: 50000
ordinal: 50000,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -716,3 +722,6 @@ /** @internal */

label: "ERROR",
ordinal: 40000
ordinal: 40000,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -725,3 +734,6 @@ /** @internal */

label: "WARN",
ordinal: 30000
ordinal: 30000,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -734,3 +746,6 @@ /** @internal */

label: "INFO",
ordinal: 20000
ordinal: 20000,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -743,3 +758,6 @@ /** @internal */

label: "DEBUG",
ordinal: 10000
ordinal: 10000,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -752,3 +770,6 @@ /** @internal */

label: "TRACE",
ordinal: 0
ordinal: 0,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -761,3 +782,6 @@ /** @internal */

label: "OFF",
ordinal: Number.MAX_SAFE_INTEGER
ordinal: Number.MAX_SAFE_INTEGER,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -862,2 +886,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -919,3 +946,6 @@ /** @internal */

fork: options.fork,
join: options.join ?? ((_, n) => n)
join: options.join ?? ((_, n) => n),
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
});

@@ -1468,3 +1498,6 @@ /** @internal */

state: MutableRef.make(deferred.pending([])),
blockingOn: fiberId
blockingOn: fiberId,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
});

@@ -1471,0 +1504,0 @@ /* @internal */

9

internal/effect/circular.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Predicate = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Predicate"));

@@ -238,2 +239,5 @@ var Exit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Exit"));

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -289,5 +293,8 @@ _b = SynchronizedTypeId, _c = internalRef.RefTypeId;

}))(optionB))(optionA)),
interruptAsFork: id => core.zipRight(self.interruptAsFork(id), that.interruptAsFork(id))
interruptAsFork: id => core.zipRight(self.interruptAsFork(id), that.interruptAsFork(id)),
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}));
exports.zipWithFiber = zipWithFiber;
//# sourceMappingURL=circular.js.map

16

internal/fiber.js

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

var order = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Order"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Clock = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Clock"));

@@ -35,2 +36,9 @@ var Exit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Exit"));

exports.fiberVariance = fiberVariance;
const fiberProto = {
[FiberTypeId]: fiberVariance,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};
/** @internal */
const RuntimeFiberSymbolKey = "@effect/io/Fiber";

@@ -57,3 +65,3 @@ /** @internal */

const done = exit => ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => FiberId.none,

@@ -111,3 +119,3 @@ await: () => core.succeed(exit),

const mapEffect = /*#__PURE__*/(0, _Function.dual)(2, (self, f) => ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => self.id(),

@@ -151,3 +159,3 @@ await: () => core.flatMap(self.await(), Exit.forEachEffect(f)),

const never = {
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => FiberId.none,

@@ -163,3 +171,3 @@ await: () => core.never,

const orElse = /*#__PURE__*/(0, _Function.dual)(2, (self, that) => ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => FiberId.getOrElse(self.id(), that.id()),

@@ -166,0 +174,0 @@ await: () => core.zipWith(self.await(), that.await(), (exit1, exit2) => Exit.isSuccess(exit1) ? exit1 : exit2),

4

internal/fiberRefs.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Arr = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));

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

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -34,0 +38,0 @@ exports.FiberRefsImpl = FiberRefsImpl;

10

internal/hub.js

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

var MutableRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/MutableRef"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/cause"));

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

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
isEmpty() {

@@ -651,2 +655,5 @@ return this.subscribers === 0;

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
capacity() {

@@ -827,2 +834,5 @@ return this.hub.capacity;

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -829,0 +839,0 @@ _b = queue.EnqueueTypeId;

4

internal/keyedPool.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

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

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -46,0 +50,0 @@ _a = KeyedPoolTypeId;

6

internal/layer.js

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

var _Function = /*#__PURE__*/require("@effect/data/Function");
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Cause"));

@@ -42,3 +43,6 @@ var Clock = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Clock"));

const proto = {
[LayerTypeId]: layerVariance
[LayerTypeId]: layerVariance,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -45,0 +49,0 @@ /** @internal */

16

internal/logger.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Cause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/cause"));

@@ -31,3 +32,6 @@ var Pretty = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/cause-pretty"));

[LoggerTypeId]: loggerVariance,
log
log,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
});

@@ -50,3 +54,6 @@ /** @internal */

[LoggerTypeId]: loggerVariance,
log: _Function.constVoid
log: _Function.constVoid,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -59,3 +66,6 @@ /** @internal */

message
}) => log(message)
}) => log(message),
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
});

@@ -62,0 +72,0 @@ /** @internal */

6

internal/metric.js

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

var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/HashSet"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var ReadonlyArray = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));

@@ -43,3 +44,6 @@ var Clock = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Clock"));

unsafeUpdate,
unsafeValue
unsafeValue,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
});

@@ -46,0 +50,0 @@ return metric;

4

internal/metric/boundaries.js

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

var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var ReadonlyArray = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));

@@ -32,2 +33,5 @@ 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); }

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -34,0 +38,0 @@ /** @internal */

7

internal/metric/hook.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var ReadonlyArray = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));

@@ -31,2 +32,5 @@ var metricState = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/metric/state"));

[MetricHookTypeId]: metricHookVariance,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
...options

@@ -38,2 +42,5 @@ });

[MetricHookTypeId]: metricHookVariance,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
get: self.get,

@@ -40,0 +47,0 @@ update: input => {

4

internal/metric/key.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var metricKeyType = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/metric/keyType"));

@@ -42,2 +43,5 @@ var metricLabel = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/metric/label"));

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -44,0 +48,0 @@ /** @internal */

1

internal/metric/keyType.d.ts

@@ -21,2 +21,3 @@ import type * as Chunk from "@effect/data/Chunk";

[Equal.symbol](that: unknown): boolean;
pipe(): unknown;
}

@@ -23,0 +24,0 @@ /**

16

internal/metric/keyType.js

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

var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
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); }

@@ -61,2 +62,5 @@ 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; }

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -75,2 +79,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -89,2 +96,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

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

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -126,2 +139,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -128,0 +144,0 @@ /**

4

internal/metric/label.js

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

var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
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,2 +32,5 @@ 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; }

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -33,0 +37,0 @@ /** @internal */

11

internal/metric/pair.js

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

exports.unsafeMake = exports.make = exports.MetricPairTypeId = void 0;
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
/** @internal */

@@ -22,3 +23,6 @@ const MetricPairSymbolKey = "@effect/io/Metric/Pair";

metricKey,
metricState
metricState,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -32,3 +36,6 @@ };

metricKey,
metricState
metricState,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
};

@@ -35,0 +42,0 @@ };

13

internal/metric/polling.js

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

var _Function = /*#__PURE__*/require("@effect/data/Function");
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

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

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
metric,

@@ -35,2 +39,5 @@ poll

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
metric: metric.make(Array.of(void 0), (inputs, extraTags) => {

@@ -59,2 +66,5 @@ for (let i = 0; i < inputs.length; i++) {

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
metric: self.metric,

@@ -67,2 +77,5 @@ poll: schedule.retry_Effect(self.poll, policy)

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
metric: metric.zip(that.metric)(self.metric),

@@ -69,0 +82,0 @@ poll: core.zip(self.poll, that.poll)

16

internal/metric/state.js

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

var Hash = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Hash"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
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); }

@@ -60,2 +61,5 @@ 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; }

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -75,2 +79,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -90,2 +97,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -109,2 +119,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -130,2 +143,5 @@ /** @internal */

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -132,0 +148,0 @@ /** @internal */

4

internal/pool.js

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

var HashSet = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/HashSet"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

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

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
get() {

@@ -91,0 +95,0 @@ const acquire = () => core.flatMap(ref.get(this.isShuttingDown), down => down ? core.interrupt : core.flatten(ref.modify(this.state, state => {

4

internal/queue.js

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

var MutableRef = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/MutableRef"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var ReadonlyArray = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray"));

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

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
capacity() {

@@ -65,0 +69,0 @@ return MutableQueue.capacity(this.queue);

4

internal/ref.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

@@ -38,2 +39,5 @@ 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); }

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -40,0 +44,0 @@ _a = RefTypeId;

4

internal/runtime.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Exit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Exit"));

@@ -213,2 +214,5 @@ var Fiber = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Fiber"));

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -215,0 +219,0 @@ /** @internal */

4

internal/schedule.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Clock = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Clock"));

@@ -56,2 +57,5 @@ var internalCause = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/cause"));

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
}

@@ -58,0 +62,0 @@ _a = ScheduleTypeId;

4

internal/scopedCache.js

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

var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var Exit = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Exit"));

@@ -99,2 +100,5 @@ var _cache = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/cache"));

}
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
}
cacheStats() {

@@ -101,0 +105,0 @@ return core.sync(() => _cache.makeCacheStats({

4

internal/scopedRef.js

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

var _Function = /*#__PURE__*/require("@effect/data/Function");
var _Pipeable = /*#__PURE__*/require("@effect/data/Pipeable");
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core"));

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

[ScopedRefTypeId]: scopedRefVariance,
pipe() {
return (0, _Pipeable.pipeArguments)(this, arguments);
},
ref

@@ -35,0 +39,0 @@ };

3

KeyedPool.d.ts

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

import type * as Duration from "@effect/data/Duration";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -25,3 +26,3 @@ import type * as Scope from "@effect/io/Scope";

*/
export interface KeyedPool<K, E, A> extends KeyedPool.Variance<K, E, A> {
export interface KeyedPool<K, E, A> extends KeyedPool.Variance<K, E, A>, Pipeable<KeyedPool<K, E, A>> {
/**

@@ -28,0 +29,0 @@ * Retrieves an item from the pool belonging to the given key in a scoped

3

Layer.d.ts

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

import type { LazyArg } from "@effect/data/Function";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Cause from "@effect/io/Cause";

@@ -43,3 +44,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface Layer<RIn, E, ROut> extends Layer.Variance<RIn, E, ROut> {
export interface Layer<RIn, E, ROut> extends Layer.Variance<RIn, E, ROut>, Pipeable<Layer<RIn, E, ROut>> {
}

@@ -46,0 +47,0 @@ /**

3

Logger.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Cause from "@effect/io/Cause";

@@ -31,3 +32,3 @@ import type { Effect } from "@effect/io/Effect";

*/
export interface Logger<Message, Output> extends Logger.Variance<Message, Output> {
export interface Logger<Message, Output> extends Logger.Variance<Message, Output>, Pipeable<Logger<Message, Output>> {
readonly log: (options: {

@@ -34,0 +35,0 @@ readonly fiberId: FiberId.FiberId;

19

Logger/Level.d.ts
import * as order from "@effect/data/Order";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -15,3 +16,3 @@ /**

*/
export type LogLevel = All | Fatal | Error | Warning | Info | Debug | Trace | None;
export type LogLevel = (All | Fatal | Error | Warning | Info | Debug | Trace | None) & Pipeable<LogLevel>;
/**

@@ -26,3 +27,3 @@ * @since 1.0.0

*/
export interface All {
export interface All extends Pipeable<All> {
readonly _tag: "All";

@@ -37,3 +38,3 @@ readonly label: "ALL";

*/
export interface Fatal {
export interface Fatal extends Pipeable<Fatal> {
readonly _tag: "Fatal";

@@ -48,3 +49,3 @@ readonly label: "FATAL";

*/
export interface Error {
export interface Error extends Pipeable<Error> {
readonly _tag: "Error";

@@ -59,3 +60,3 @@ readonly label: "ERROR";

*/
export interface Warning {
export interface Warning extends Pipeable<Warning> {
readonly _tag: "Warning";

@@ -70,3 +71,3 @@ readonly label: "WARN";

*/
export interface Info {
export interface Info extends Pipeable<Info> {
readonly _tag: "Info";

@@ -81,3 +82,3 @@ readonly label: "INFO";

*/
export interface Debug {
export interface Debug extends Pipeable<Debug> {
readonly _tag: "Debug";

@@ -92,3 +93,3 @@ readonly label: "DEBUG";

*/
export interface Trace {
export interface Trace extends Pipeable<Trace> {
readonly _tag: "Trace";

@@ -103,3 +104,3 @@ readonly label: "TRACE";

*/
export interface None {
export interface None extends Pipeable<None> {
readonly _tag: "None";

@@ -106,0 +107,0 @@ readonly label: "OFF";

3

Metric.d.ts

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

import type * as HashSet from "@effect/data/HashSet";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -47,3 +48,3 @@ import type * as MetricBoundaries from "@effect/io/Metric/Boundaries";

*/
export interface Metric<Type, In, Out> extends Metric.Variance<Type, In, Out> {
export interface Metric<Type, In, Out> extends Metric.Variance<Type, In, Out>, Pipeable<Metric<Type, In, Out>> {
/**

@@ -50,0 +51,0 @@ * The type of the underlying primitive metric. For example, this could be

3

Metric/Boundaries.d.ts

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

import type * as Equal from "@effect/data/Equal";
import type { Pipeable } from "@effect/data/Pipeable";
/**

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

*/
export interface MetricBoundaries extends Equal.Equal {
export interface MetricBoundaries extends Equal.Equal, Pipeable<MetricBoundaries> {
readonly [MetricBoundariesTypeId]: MetricBoundariesTypeId;

@@ -24,0 +25,0 @@ readonly values: Chunk.Chunk<number>;

3

Metric/Hook.d.ts

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

import type { LazyArg } from "@effect/data/Function";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as MetricKey from "@effect/io/Metric/Key";

@@ -22,3 +23,3 @@ import type * as MetricState from "@effect/io/Metric/State";

*/
export interface MetricHook<In, Out> extends MetricHook.Variance<In, Out> {
export interface MetricHook<In, Out> extends MetricHook.Variance<In, Out>, Pipeable<MetricHook<In, Out>> {
readonly get: () => Out;

@@ -25,0 +26,0 @@ readonly update: (input: In) => void;

3

Metric/Key.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as MetricBoundaries from "@effect/io/Metric/Boundaries";

@@ -33,3 +34,3 @@ import type * as MetricKeyType from "@effect/io/Metric/KeyType";

*/
export interface MetricKey<Type extends MetricKeyType.MetricKeyType<any, any>> extends MetricKey.Variance<Type>, Equal.Equal {
export interface MetricKey<Type extends MetricKeyType.MetricKeyType<any, any>> extends MetricKey.Variance<Type>, Equal.Equal, Pipeable<MetricKey<Type>> {
readonly name: string;

@@ -36,0 +37,0 @@ readonly keyType: Type;

3

Metric/KeyType.d.ts

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

import type * as Equal from "@effect/data/Equal";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as MetricBoundaries from "@effect/io/Metric/Boundaries";

@@ -74,3 +75,3 @@ import type * as MetricState from "@effect/io/Metric/State";

*/
export interface MetricKeyType<In, Out> extends MetricKeyType.Variance<In, Out>, Equal.Equal {
export interface MetricKeyType<In, Out> extends MetricKeyType.Variance<In, Out>, Equal.Equal, Pipeable<MetricKeyType<In, Out>> {
}

@@ -77,0 +78,0 @@ /**

3

Metric/Label.d.ts

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

import type * as Equal from "@effect/data/Equal";
import type { Pipeable } from "@effect/data/Pipeable";
/**

@@ -27,3 +28,3 @@ * @since 1.0.0

*/
export interface MetricLabel extends Equal.Equal {
export interface MetricLabel extends Equal.Equal, Pipeable<MetricLabel> {
readonly [MetricLabelTypeId]: MetricLabelTypeId;

@@ -30,0 +31,0 @@ readonly key: string;

6

Metric/Pair.d.ts

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

/**
* @since 1.0.0
*/
import type { Pipeable } from "@effect/data/Pipeable";
import type * as MetricKey from "@effect/io/Metric/Key";

@@ -18,3 +22,3 @@ import type * as MetricKeyType from "@effect/io/Metric/KeyType";

*/
export interface MetricPair<Type extends MetricKeyType.MetricKeyType<any, any>> extends MetricPair.Variance<Type> {
export interface MetricPair<Type extends MetricKeyType.MetricKeyType<any, any>> extends MetricPair.Variance<Type>, Pipeable<MetricPair<Type>> {
readonly metricKey: MetricKey.MetricKey<Type>;

@@ -21,0 +25,0 @@ readonly metricState: MetricState.MetricState<MetricKeyType.MetricKeyType.OutType<Type>>;

4

Metric/Pair.js

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

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

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

3

Metric/Polling.d.ts
/**
* @since 1.0.0
*/
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -26,3 +27,3 @@ import type * as Fiber from "@effect/io/Fiber";

*/
export interface PollingMetric<Type, In, R, E, Out> {
export interface PollingMetric<Type, In, R, E, Out> extends Pipeable<PollingMetric<Type, In, R, E, Out>> {
readonly [PollingMetricTypeId]: PollingMetricTypeId;

@@ -29,0 +30,0 @@ /**

3

Metric/State.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as MetricKeyType from "@effect/io/Metric/KeyType";

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

*/
export interface MetricState<A> extends MetricState.Variance<A>, Equal.Equal {
export interface MetricState<A> extends MetricState.Variance<A>, Equal.Equal, Pipeable<MetricState<A>> {
}

@@ -81,0 +82,0 @@ /**

4

package.json
{
"name": "@effect/io",
"version": "0.31.2",
"version": "0.31.3",
"license": "MIT",

@@ -10,3 +10,3 @@ "repository": {

"dependencies": {
"@effect/data": "^0.13.4"
"@effect/data": "^0.13.5"
},

@@ -13,0 +13,0 @@ "publishConfig": {

3

Pool.d.ts

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

import type * as Duration from "@effect/data/Duration";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -27,3 +28,3 @@ import type * as Scope from "@effect/io/Scope";

*/
export interface Pool<E, A> extends Data.Case, Pool.Variance<E, A> {
export interface Pool<E, A> extends Data.Case, Pool.Variance<E, A>, Pipeable<Pool<E, A>> {
/**

@@ -30,0 +31,0 @@ * Retrieves an item from the pool in a scoped effect. Note that if

7

Queue.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable, PipeableOverride } from "@effect/data/Pipeable";
import type * as Deferred from "@effect/io/Deferred";

@@ -45,3 +46,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface Queue<A> extends Enqueue<A>, Dequeue<A> {
export interface Queue<A> extends PipeableOverride<Enqueue<A>, Queue<A>>, PipeableOverride<Dequeue<A>, Queue<A>> {
}

@@ -52,3 +53,3 @@ /**

*/
export interface Enqueue<A> extends Queue.EnqueueVariance<A>, BaseQueue {
export interface Enqueue<A> extends Queue.EnqueueVariance<A>, BaseQueue, Pipeable<Enqueue<A>> {
/**

@@ -83,3 +84,3 @@ * Places one value in the queue.

*/
export interface Dequeue<A> extends Queue.DequeueVariance<A>, BaseQueue {
export interface Dequeue<A> extends Queue.DequeueVariance<A>, BaseQueue, Pipeable<Dequeue<A>> {
/**

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

3

Ref.d.ts

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

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

@@ -21,3 +22,3 @@ /**

*/
export interface Ref<A> extends Ref.Variance<A> {
export interface Ref<A> extends Ref.Variance<A>, Pipeable<Ref<A>> {
modify<B>(f: (a: A) => readonly [B, A]): Effect.Effect<never, never, B>;

@@ -24,0 +25,0 @@ }

3

RequestResolver.d.ts

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

import type * as Equal from "@effect/data/Equal";
import type { Pipeable } from "@effect/data/Pipeable";
import * as Effect from "@effect/io/Effect";

@@ -45,3 +46,3 @@ import type { FiberRef } from "@effect/io/FiberRef";

*/
export interface RequestResolver<A, R = never> extends Equal.Equal {
export interface RequestResolver<A, R = never> extends Equal.Equal, Pipeable<RequestResolver<A, R>> {
/**

@@ -48,0 +49,0 @@ * Execute a collection of requests. The outer `Chunk` represents batches

3

Runtime.d.ts

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

import type * as Context from "@effect/data/Context";
import type { Pipeable } from "@effect/data/Pipeable";
import type { Cause } from "@effect/io/Cause";

@@ -33,3 +34,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface Runtime<R> {
export interface Runtime<R> extends Pipeable<Runtime<R>> {
/**

@@ -36,0 +37,0 @@ * The context used as initial for forks

3

Schedule.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type { Predicate } from "@effect/data/Predicate";

@@ -64,3 +65,3 @@ import type * as Cause from "@effect/io/Cause";

*/
export interface Schedule<Env, In, Out> extends Schedule.Variance<Env, In, Out> {
export interface Schedule<Env, In, Out> extends Schedule.Variance<Env, In, Out>, Pipeable<Schedule<Env, In, Out>> {
/**

@@ -67,0 +68,0 @@ * Initial State

5

Scope.d.ts

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

import type * as Context from "@effect/data/Context";
import type { Pipeable, PipeableOverride } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -33,3 +34,3 @@ import type * as ExecutionStrategy from "@effect/io/ExecutionStrategy";

*/
export interface Scope {
export interface Scope extends Pipeable<Scope> {
readonly [ScopeTypeId]: ScopeTypeId;

@@ -41,3 +42,3 @@ }

*/
export interface CloseableScope extends Scope {
export interface CloseableScope extends PipeableOverride<Scope, CloseableScope> {
readonly [CloseableScopeTypeId]: CloseableScopeTypeId;

@@ -44,0 +45,0 @@ }

3

ScopedCache.d.ts

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

import type * as Option from "@effect/data/Option";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Cache from "@effect/io/Cache";

@@ -25,3 +26,3 @@ import type * as Effect from "@effect/io/Effect";

*/
export interface ScopedCache<Key, Error, Value> extends ScopedCache.Variance<Key, Error, Value> {
export interface ScopedCache<Key, Error, Value> extends ScopedCache.Variance<Key, Error, Value>, Pipeable<ScopedCache<Key, Error, Value>> {
/**

@@ -28,0 +29,0 @@ * Retrieves the value associated with the specified key if it exists.

3

ScopedRef.d.ts

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

import type { LazyArg } from "@effect/data/Function";
import type { Pipeable } from "@effect/data/Pipeable";
import type * as Effect from "@effect/io/Effect";

@@ -28,3 +29,3 @@ import type * as Scope from "@effect/io/Scope";

*/
export interface ScopedRef<A> extends ScopedRef.Variance<A> {
export interface ScopedRef<A> extends ScopedRef.Variance<A>, Pipeable<ScopedRef<A>> {
}

@@ -31,0 +32,0 @@ /**

32

src/Cause.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type { Predicate } from "@effect/data/Predicate"

@@ -132,9 +133,12 @@ import type * as FiberId from "@effect/io/Fiber/Id"

export type Cause<E> =
| Empty
| Fail<E>
| Die
| Interrupt
| Annotated<E>
| Sequential<E>
| Parallel<E>
& (
| Empty
| Fail<E>
| Die
| Interrupt
| Annotated<E>
| Sequential<E>
| Parallel<E>
)
& Pipeable<Cause<E>>

@@ -248,3 +252,3 @@ /**

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

@@ -260,3 +264,3 @@ }

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

@@ -274,3 +278,3 @@ readonly error: E

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

@@ -287,3 +291,3 @@ readonly defect: unknown

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

@@ -302,3 +306,3 @@ readonly fiberId: FiberId.FiberId

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

@@ -322,3 +326,3 @@ readonly cause: Cause<E>

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

@@ -341,3 +345,3 @@ readonly left: Cause<E>

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

@@ -344,0 +348,0 @@ readonly left: Cause<E>

3

src/Config.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type { Predicate, Refinement } from "@effect/data/Predicate"

@@ -47,3 +48,3 @@ import type * as ConfigError from "@effect/io/Config/Error"

*/
export interface Config<A> extends Config.Variance<A> {}
export interface Config<A> extends Config.Variance<A>, Pipeable<Config<A>> {}

@@ -50,0 +51,0 @@ /**

3

src/Config/Provider.ts

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

import type * as HashSet from "@effect/data/HashSet"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Config from "@effect/io/Config"

@@ -45,3 +46,3 @@ import type * as ConfigError from "@effect/io/Config/Error"

*/
export interface ConfigProvider extends ConfigProvider.Proto {
export interface ConfigProvider extends ConfigProvider.Proto, Pipeable<ConfigProvider> {
/**

@@ -48,0 +49,0 @@ * Loads the specified configuration, or fails with a config error.

3

src/Deferred.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -39,3 +40,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface Deferred<E, A> extends Deferred.Variance<E, A> {
export interface Deferred<E, A> extends Deferred.Variance<E, A>, Pipeable<Deferred<E, A>> {
/** @internal */

@@ -42,0 +43,0 @@ readonly state: MutableRef.MutableRef<internal.State<E, A>>

7

src/Exit.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable, PipeableOverride } from "@effect/data/Pipeable"
import type { Predicate } from "@effect/data/Predicate"

@@ -24,3 +25,3 @@ import type * as Unify from "@effect/data/Unify"

*/
export type Exit<E, A> = Failure<E, A> | Success<E, A>
export type Exit<E, A> = (Failure<E, A> | Success<E, A>) & Pipeable<Exit<E, A>>

@@ -34,3 +35,3 @@ /**

*/
export interface Failure<E, A> extends Effect.Effect<never, E, A> {
export interface Failure<E, A> extends PipeableOverride<Effect.Effect<never, E, A>, Failure<E, A>> {
readonly _tag: "Failure"

@@ -68,3 +69,3 @@ readonly cause: Cause.Cause<E>

*/
export interface Success<E, A> extends Effect.Effect<never, E, A> {
export interface Success<E, A> extends PipeableOverride<Effect.Effect<never, E, A>, Success<E, A>> {
readonly _tag: "Success"

@@ -71,0 +72,0 @@ readonly value: A

3

src/Fiber.ts

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

import type * as order from "@effect/data/Order"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -58,3 +59,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface Fiber<E, A> extends Fiber.Variance<E, A> {
export interface Fiber<E, A> extends Fiber.Variance<E, A>, Pipeable<Fiber<E, A>> {
/**

@@ -61,0 +62,0 @@ * The identity of the fiber.

3

src/FiberRef.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -44,3 +45,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface FiberRef<A> extends Variance<A> {
export interface FiberRef<A> extends Variance<A>, Pipeable<FiberRef<A>> {
/** @internal */

@@ -47,0 +48,0 @@ readonly initial: A

3

src/FiberRefs.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Arr from "@effect/data/ReadonlyArray"

@@ -34,3 +35,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface FiberRefs {
export interface FiberRefs extends Pipeable<FiberRefs> {
readonly [FiberRefsSym]: FiberRefsSym

@@ -37,0 +38,0 @@ readonly locals: Map<FiberRef.FiberRef<any>, Arr.NonEmptyReadonlyArray<readonly [FiberId.Runtime, any]>>

3

src/Hub.ts
/**
* @since 1.0.0
*/
import type { PipeableOverride } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -17,3 +18,3 @@ import * as internal from "@effect/io/internal/hub"

*/
export interface Hub<A> extends Queue.Enqueue<A> {
export interface Hub<A> extends PipeableOverride<Queue.Enqueue<A>, Hub<A>> {
/**

@@ -20,0 +21,0 @@ * Publishes a message to the hub, returning whether the message was published

4

src/internal/cause.ts

@@ -15,2 +15,3 @@ import * as Chunk from "@effect/data/Chunk"

import * as MRef from "@effect/data/MutableRef"
import { pipeArguments } from "@effect/data/Pipeable"

@@ -45,2 +46,5 @@ // -----------------------------------------------------------------------------

return isCause(that) && causeEquals(this, that)
},
pipe() {
return pipeArguments(this, arguments)
}

@@ -47,0 +51,0 @@ }

6

src/internal/config.ts

@@ -8,2 +8,3 @@ import * as Chunk from "@effect/data/Chunk"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type { Predicate, Refinement } from "@effect/data/Predicate"

@@ -48,3 +49,6 @@ import type * as Config from "@effect/io/Config"

const proto = {
[ConfigTypeId]: configVariance
[ConfigTypeId]: configVariance,
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -51,0 +55,0 @@

4

src/internal/configProvider.ts

@@ -9,2 +9,3 @@ import * as Context from "@effect/data/Context"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import * as RA from "@effect/data/ReadonlyArray"

@@ -54,2 +55,5 @@ import type * as Config from "@effect/io/Config"

[ConfigProviderTypeId]: ConfigProviderTypeId,
pipe() {
return pipeArguments(this, arguments)
},
...options

@@ -56,0 +60,0 @@ })

9

src/internal/effect/circular.ts

@@ -10,2 +10,3 @@ import * as Duration from "@effect/data/Duration"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import * as Predicate from "@effect/data/Predicate"

@@ -508,2 +509,5 @@ import type * as Cause from "@effect/io/Cause"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -615,3 +619,6 @@

that.interruptAsFork(id)
)
),
pipe() {
return pipeArguments(this, arguments)
}
}))

17

src/internal/fiber.ts

@@ -7,2 +7,3 @@ import * as Either from "@effect/data/Either"

import * as order from "@effect/data/Order"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -34,2 +35,10 @@ import * as Clock from "@effect/io/Clock"

/** @internal */
const fiberProto = {
[FiberTypeId]: fiberVariance,
pipe() {
return pipeArguments(this, arguments)
}
}
/** @internal */
const RuntimeFiberSymbolKey = "@effect/io/Fiber"

@@ -71,3 +80,3 @@

export const done = <E, A>(exit: Exit.Exit<E, A>): Fiber.Fiber<E, A> => ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => FiberId.none,

@@ -144,3 +153,3 @@ await: () => core.succeed(exit),

>(2, (self, f) => ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => self.id(),

@@ -212,3 +221,3 @@ await: () => core.flatMap(self.await(), Exit.forEachEffect(f)),

export const never: Fiber.Fiber<never, never> = ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => FiberId.none,

@@ -227,3 +236,3 @@ await: () => core.never,

>(2, (self, that) => ({
[FiberTypeId]: fiberVariance,
...fiberProto,
id: () => FiberId.getOrElse(self.id(), that.id()),

@@ -230,0 +239,0 @@ await: () =>

4

src/internal/fiberRefs.ts

@@ -5,2 +5,3 @@ import * as Equal from "@effect/data/Equal"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import * as Arr from "@effect/data/ReadonlyArray"

@@ -33,2 +34,5 @@ import type * as Effect from "@effect/io/Effect"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -35,0 +39,0 @@

13

src/internal/hub.ts

@@ -5,2 +5,3 @@ import * as Chunk from "@effect/data/Chunk"

import * as MutableRef from "@effect/data/MutableRef"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Deferred from "@effect/io/Deferred"

@@ -529,2 +530,6 @@ import type * as Effect from "@effect/io/Effect"

pipe() {
return pipeArguments(this, arguments)
}
isEmpty(): boolean {

@@ -828,2 +833,6 @@ return this.subscribers === 0

pipe() {
return pipeArguments(this, arguments)
}
capacity(): number {

@@ -1110,2 +1119,6 @@ return this.hub.capacity

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -1112,0 +1125,0 @@

4

src/internal/keyedPool.ts

@@ -8,2 +8,3 @@ import * as Duration from "@effect/data/Duration"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Deferred from "@effect/io/Deferred"

@@ -47,2 +48,5 @@ import type * as Effect from "@effect/io/Effect"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -49,0 +53,0 @@

6

src/internal/layer.ts

@@ -5,2 +5,3 @@ import * as Context from "@effect/data/Context"

import { dual, pipe } from "@effect/data/Function"
import { pipeArguments } from "@effect/data/Pipeable"
import * as Cause from "@effect/io/Cause"

@@ -46,3 +47,6 @@ import * as Clock from "@effect/io/Clock"

const proto = {
[LayerTypeId]: layerVariance
[LayerTypeId]: layerVariance,
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -49,0 +53,0 @@

16

src/internal/logger.ts

@@ -6,2 +6,3 @@ import type { LazyArg } from "@effect/data/Function"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as CauseExt from "@effect/io/Cause"

@@ -47,3 +48,6 @@ import type * as FiberId from "@effect/io/Fiber/Id"

[LoggerTypeId]: loggerVariance,
log
log,
pipe() {
return pipeArguments(this, arguments)
}
})

@@ -95,3 +99,6 @@

[LoggerTypeId]: loggerVariance,
log: constVoid
log: constVoid,
pipe() {
return pipeArguments(this, arguments)
}
} as Logger.Logger<unknown, void>

@@ -102,3 +109,6 @@

[LoggerTypeId]: loggerVariance,
log: ({ message }) => log(message)
log: ({ message }) => log(message),
pipe() {
return pipeArguments(this, arguments)
}
})

@@ -105,0 +115,0 @@

6

src/internal/metric.ts

@@ -7,2 +7,3 @@ import type * as Chunk from "@effect/data/Chunk"

import * as HashSet from "@effect/data/HashSet"
import { pipeArguments } from "@effect/data/Pipeable"
import * as ReadonlyArray from "@effect/data/ReadonlyArray"

@@ -65,3 +66,6 @@ import * as Clock from "@effect/io/Clock"

unsafeUpdate,
unsafeValue
unsafeValue,
pipe() {
return pipeArguments(this, arguments)
}
} as const

@@ -68,0 +72,0 @@ )

4

src/internal/metric/boundaries.ts

@@ -5,2 +5,3 @@ import * as Chunk from "@effect/data/Chunk"

import * as Hash from "@effect/data/Hash"
import { pipeArguments } from "@effect/data/Pipeable"
import * as ReadonlyArray from "@effect/data/ReadonlyArray"

@@ -30,2 +31,5 @@ import type * as MetricBoundaries from "@effect/io/Metric/Boundaries"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -32,0 +36,0 @@

7

src/internal/metric/hook.ts

@@ -8,2 +8,3 @@ import * as Chunk from "@effect/data/Chunk"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import * as ReadonlyArray from "@effect/data/ReadonlyArray"

@@ -36,2 +37,5 @@ import * as metricState from "@effect/io/internal/metric/state"

[MetricHookTypeId]: metricHookVariance,
pipe() {
return pipeArguments(this, arguments)
},
...options

@@ -46,2 +50,5 @@ })

[MetricHookTypeId]: metricHookVariance,
pipe() {
return pipeArguments(this, arguments)
},
get: self.get,

@@ -48,0 +55,0 @@ update: (input) => {

4

src/internal/metric/key.ts

@@ -8,2 +8,3 @@ import type * as Chunk from "@effect/data/Chunk"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import * as metricKeyType from "@effect/io/internal/metric/keyType"

@@ -53,2 +54,5 @@ import * as metricLabel from "@effect/io/internal/metric/label"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -55,0 +59,0 @@

16

src/internal/metric/keyType.ts

@@ -6,2 +6,3 @@ import type * as Chunk from "@effect/data/Chunk"

import * as Hash from "@effect/data/Hash"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as MetricBoundaries from "@effect/io/Metric/Boundaries"

@@ -74,2 +75,5 @@ import type * as MetricKeyType from "@effect/io/Metric/KeyType"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -87,2 +91,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -100,2 +107,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -120,2 +130,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -149,2 +162,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -151,0 +167,0 @@

4

src/internal/metric/label.ts
import * as Equal from "@effect/data/Equal"
import { pipe } from "@effect/data/Function"
import * as Hash from "@effect/data/Hash"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as MetricLabel from "@effect/io/Metric/Label"

@@ -30,2 +31,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -32,0 +36,0 @@

11

src/internal/metric/pair.ts

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

import { pipeArguments } from "@effect/data/Pipeable"
import type * as MetricKey from "@effect/io/Metric/Key"

@@ -27,3 +28,6 @@ import type * as MetricKeyType from "@effect/io/Metric/KeyType"

metricKey,
metricState
metricState,
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -40,4 +44,7 @@ }

metricKey,
metricState
metricState,
pipe() {
return pipeArguments(this, arguments)
}
}
}

13

src/internal/metric/polling.ts
import { dual, pipe } from "@effect/data/Function"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -28,2 +29,5 @@ import type * as Fiber from "@effect/io/Fiber"

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return pipeArguments(this, arguments)
},
metric,

@@ -41,2 +45,5 @@ poll

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return pipeArguments(this, arguments)
},
metric: metric.make(

@@ -101,2 +108,5 @@ Array.of<any>(void 0) as Array<any>,

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return pipeArguments(this, arguments)
},
metric: self.metric,

@@ -131,4 +141,7 @@ poll: schedule.retry_Effect(self.poll, policy)

[PollingMetricTypeId]: PollingMetricTypeId,
pipe() {
return pipeArguments(this, arguments)
},
metric: pipe(self.metric, metric.zip(that.metric)),
poll: core.zip(self.poll, that.poll)
}))

16

src/internal/metric/state.ts

@@ -7,2 +7,3 @@ import type * as Chunk from "@effect/data/Chunk"

import type * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as MetricState from "@effect/io/Metric/State"

@@ -77,2 +78,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -94,2 +98,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -111,2 +118,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -143,2 +153,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -178,2 +191,5 @@

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -180,0 +196,0 @@

5

src/internal/pool.ts

@@ -7,2 +7,3 @@ import * as Context from "@effect/data/Context"

import * as HashSet from "@effect/data/HashSet"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Clock from "@effect/io/Clock"

@@ -171,2 +172,6 @@ import type * as Effect from "@effect/io/Effect"

pipe() {
return pipeArguments(this, arguments)
}
get(): Effect.Effect<Scope.Scope, E, A> {

@@ -173,0 +178,0 @@ const acquire = (): Effect.Effect<never, never, Attempted<E, A>> =>

5

src/internal/queue.ts

@@ -6,2 +6,3 @@ import * as Chunk from "@effect/data/Chunk"

import type * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import * as ReadonlyArray from "@effect/data/ReadonlyArray"

@@ -68,2 +69,6 @@ import type * as Deferred from "@effect/io/Deferred"

pipe() {
return pipeArguments(this, arguments)
}
capacity(): number {

@@ -70,0 +75,0 @@ return MutableQueue.capacity(this.queue)

4

src/internal/ref.ts
import { dual } from "@effect/data/Function"
import * as MutableRef from "@effect/data/MutableRef"
import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -29,2 +30,5 @@ import * as core from "@effect/io/internal/core"

}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -31,0 +35,0 @@

5

src/internal/runtime.ts
import * as Context from "@effect/data/Context"
import { pipe } from "@effect/data/Function"
import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -248,2 +249,6 @@ import type * as Effect from "@effect/io/Effect"

) {}
pipe() {
return pipeArguments(this, arguments)
}
}

@@ -250,0 +255,0 @@

5

src/internal/scopedCache.ts

@@ -11,2 +11,3 @@ import * as Context from "@effect/data/Context"

import * as Option from "@effect/data/Option"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Cache from "@effect/io/Cache"

@@ -198,2 +199,6 @@ import type * as Clock from "@effect/io/Clock"

pipe() {
return pipeArguments(this, arguments)
}
cacheStats(): Effect.Effect<never, never, Cache.CacheStats> {

@@ -200,0 +205,0 @@ return core.sync(() =>

4

src/internal/scopedRef.ts
import * as Context from "@effect/data/Context"
import type { LazyArg } from "@effect/data/Function"
import { dual, pipe } from "@effect/data/Function"
import { pipeArguments } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -53,2 +54,5 @@ import * as core from "@effect/io/internal/core"

[ScopedRefTypeId]: scopedRefVariance,
pipe() {
return pipeArguments(this, arguments)
},
ref

@@ -55,0 +59,0 @@ }

3

src/KeyedPool.ts

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

import type * as Duration from "@effect/data/Duration"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -29,3 +30,3 @@ import * as internal from "@effect/io/internal/keyedPool"

*/
export interface KeyedPool<K, E, A> extends KeyedPool.Variance<K, E, A> {
export interface KeyedPool<K, E, A> extends KeyedPool.Variance<K, E, A>, Pipeable<KeyedPool<K, E, A>> {
/**

@@ -32,0 +33,0 @@ * Retrieves an item from the pool belonging to the given key in a scoped

3

src/Layer.ts

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

import type { LazyArg } from "@effect/data/Function"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -47,3 +48,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface Layer<RIn, E, ROut> extends Layer.Variance<RIn, E, ROut> {}
export interface Layer<RIn, E, ROut> extends Layer.Variance<RIn, E, ROut>, Pipeable<Layer<RIn, E, ROut>> {}

@@ -50,0 +51,0 @@ /**

3

src/Logger.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Cause from "@effect/io/Cause"

@@ -38,3 +39,3 @@ import type { Effect } from "@effect/io/Effect"

*/
export interface Logger<Message, Output> extends Logger.Variance<Message, Output> {
export interface Logger<Message, Output> extends Logger.Variance<Message, Output>, Pipeable<Logger<Message, Output>> {
readonly log: (

@@ -41,0 +42,0 @@ options: {

19

src/Logger/Level.ts

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

import * as order from "@effect/data/Order"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -23,3 +24,3 @@ import * as core from "@effect/io/internal/core"

*/
export type LogLevel = All | Fatal | Error | Warning | Info | Debug | Trace | None
export type LogLevel = (All | Fatal | Error | Warning | Info | Debug | Trace | None) & Pipeable<LogLevel>

@@ -36,3 +37,3 @@ /**

*/
export interface All {
export interface All extends Pipeable<All> {
readonly _tag: "All"

@@ -48,3 +49,3 @@ readonly label: "ALL"

*/
export interface Fatal {
export interface Fatal extends Pipeable<Fatal> {
readonly _tag: "Fatal"

@@ -60,3 +61,3 @@ readonly label: "FATAL"

*/
export interface Error {
export interface Error extends Pipeable<Error> {
readonly _tag: "Error"

@@ -72,3 +73,3 @@ readonly label: "ERROR"

*/
export interface Warning {
export interface Warning extends Pipeable<Warning> {
readonly _tag: "Warning"

@@ -84,3 +85,3 @@ readonly label: "WARN"

*/
export interface Info {
export interface Info extends Pipeable<Info> {
readonly _tag: "Info"

@@ -96,3 +97,3 @@ readonly label: "INFO"

*/
export interface Debug {
export interface Debug extends Pipeable<Debug> {
readonly _tag: "Debug"

@@ -108,3 +109,3 @@ readonly label: "DEBUG"

*/
export interface Trace {
export interface Trace extends Pipeable<Trace> {
readonly _tag: "Trace"

@@ -120,3 +121,3 @@ readonly label: "TRACE"

*/
export interface None {
export interface None extends Pipeable<None> {
readonly _tag: "None"

@@ -123,0 +124,0 @@ readonly label: "OFF"

3

src/Metric.ts

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

import type * as HashSet from "@effect/data/HashSet"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -52,3 +53,3 @@ import * as fiberRuntime from "@effect/io/internal/fiberRuntime"

*/
export interface Metric<Type, In, Out> extends Metric.Variance<Type, In, Out> {
export interface Metric<Type, In, Out> extends Metric.Variance<Type, In, Out>, Pipeable<Metric<Type, In, Out>> {
/**

@@ -55,0 +56,0 @@ * The type of the underlying primitive metric. For example, this could be

3

src/Metric/Boundaries.ts

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

import type * as Equal from "@effect/data/Equal"
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/boundaries"

@@ -25,3 +26,3 @@

*/
export interface MetricBoundaries extends Equal.Equal {
export interface MetricBoundaries extends Equal.Equal, Pipeable<MetricBoundaries> {
readonly [MetricBoundariesTypeId]: MetricBoundariesTypeId

@@ -28,0 +29,0 @@ readonly values: Chunk.Chunk<number>

3

src/Metric/Hook.ts

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

import type { LazyArg } from "@effect/data/Function"
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/hook"

@@ -26,3 +27,3 @@ import type * as MetricKey from "@effect/io/Metric/Key"

*/
export interface MetricHook<In, Out> extends MetricHook.Variance<In, Out> {
export interface MetricHook<In, Out> extends MetricHook.Variance<In, Out>, Pipeable<MetricHook<In, Out>> {
readonly get: () => Out

@@ -29,0 +30,0 @@ readonly update: (input: In) => void

3

src/Metric/Key.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/key"

@@ -38,3 +39,3 @@ import type * as MetricBoundaries from "@effect/io/Metric/Boundaries"

export interface MetricKey<Type extends MetricKeyType.MetricKeyType<any, any>>
extends MetricKey.Variance<Type>, Equal.Equal
extends MetricKey.Variance<Type>, Equal.Equal, Pipeable<MetricKey<Type>>
{

@@ -41,0 +42,0 @@ readonly name: string

5

src/Metric/KeyType.ts

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

import type * as Equal from "@effect/data/Equal"
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/keyType"

@@ -88,3 +89,5 @@ import type * as MetricBoundaries from "@effect/io/Metric/Boundaries"

*/
export interface MetricKeyType<In, Out> extends MetricKeyType.Variance<In, Out>, Equal.Equal {}
export interface MetricKeyType<In, Out>
extends MetricKeyType.Variance<In, Out>, Equal.Equal, Pipeable<MetricKeyType<In, Out>>
{}

@@ -91,0 +94,0 @@ /**

3

src/Metric/Label.ts

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

import type * as Equal from "@effect/data/Equal"
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/label"

@@ -31,3 +32,3 @@

*/
export interface MetricLabel extends Equal.Equal {
export interface MetricLabel extends Equal.Equal, Pipeable<MetricLabel> {
readonly [MetricLabelTypeId]: MetricLabelTypeId

@@ -34,0 +35,0 @@ readonly key: string

5

src/Metric/Pair.ts
/**
* @since 1.0.0
*/
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/pair"

@@ -25,3 +26,5 @@ import type * as MetricKey from "@effect/io/Metric/Key"

*/
export interface MetricPair<Type extends MetricKeyType.MetricKeyType<any, any>> extends MetricPair.Variance<Type> {
export interface MetricPair<Type extends MetricKeyType.MetricKeyType<any, any>>
extends MetricPair.Variance<Type>, Pipeable<MetricPair<Type>>
{
readonly metricKey: MetricKey.MetricKey<Type>

@@ -28,0 +31,0 @@ readonly metricState: MetricState.MetricState<MetricKeyType.MetricKeyType.OutType<Type>>

3

src/Metric/Polling.ts
/**
* @since 1.0.0
*/
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -30,3 +31,3 @@ import type * as Fiber from "@effect/io/Fiber"

*/
export interface PollingMetric<Type, In, R, E, Out> {
export interface PollingMetric<Type, In, R, E, Out> extends Pipeable<PollingMetric<Type, In, R, E, Out>> {
readonly [PollingMetricTypeId]: PollingMetricTypeId

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

3

src/Metric/State.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import * as internal from "@effect/io/internal/metric/state"

@@ -92,3 +93,3 @@ import type * as MetricKeyType from "@effect/io/Metric/KeyType"

*/
export interface MetricState<A> extends MetricState.Variance<A>, Equal.Equal {}
export interface MetricState<A> extends MetricState.Variance<A>, Equal.Equal, Pipeable<MetricState<A>> {}

@@ -95,0 +96,0 @@ /**

3

src/Pool.ts

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

import type * as Duration from "@effect/data/Duration"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -31,3 +32,3 @@ import * as internal from "@effect/io/internal/pool"

*/
export interface Pool<E, A> extends Data.Case, Pool.Variance<E, A> {
export interface Pool<E, A> extends Data.Case, Pool.Variance<E, A>, Pipeable<Pool<E, A>> {
/**

@@ -34,0 +35,0 @@ * Retrieves an item from the pool in a scoped effect. Note that if

7

src/Queue.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable, PipeableOverride } from "@effect/data/Pipeable"
import type * as Deferred from "@effect/io/Deferred"

@@ -53,3 +54,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface Queue<A> extends Enqueue<A>, Dequeue<A> {
export interface Queue<A> extends PipeableOverride<Enqueue<A>, Queue<A>>, PipeableOverride<Dequeue<A>, Queue<A>> {
/** @internal */

@@ -71,3 +72,3 @@ readonly queue: MutableQueue.MutableQueue<A>

*/
export interface Enqueue<A> extends Queue.EnqueueVariance<A>, BaseQueue {
export interface Enqueue<A> extends Queue.EnqueueVariance<A>, BaseQueue, Pipeable<Enqueue<A>> {
/**

@@ -105,3 +106,3 @@ * Places one value in the queue.

*/
export interface Dequeue<A> extends Queue.DequeueVariance<A>, BaseQueue {
export interface Dequeue<A> extends Queue.DequeueVariance<A>, BaseQueue, Pipeable<Dequeue<A>> {
/**

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

3

src/Ref.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -25,3 +26,3 @@ import * as internal from "@effect/io/internal/ref"

*/
export interface Ref<A> extends Ref.Variance<A> {
export interface Ref<A> extends Ref.Variance<A>, Pipeable<Ref<A>> {
modify<B>(f: (a: A) => readonly [B, A]): Effect.Effect<never, never, B>

@@ -28,0 +29,0 @@ }

3

src/RequestResolver.ts

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

import type * as Equal from "@effect/data/Equal"
import type { Pipeable } from "@effect/data/Pipeable"
import * as Effect from "@effect/io/Effect"

@@ -51,3 +52,3 @@ import type { FiberRef } from "@effect/io/FiberRef"

*/
export interface RequestResolver<A, R = never> extends Equal.Equal {
export interface RequestResolver<A, R = never> extends Equal.Equal, Pipeable<RequestResolver<A, R>> {
/**

@@ -54,0 +55,0 @@ * Execute a collection of requests. The outer `Chunk` represents batches

3

src/Runtime.ts

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

import type * as Context from "@effect/data/Context"
import type { Pipeable } from "@effect/data/Pipeable"
import type { Cause } from "@effect/io/Cause"

@@ -37,3 +38,3 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface Runtime<R> {
export interface Runtime<R> extends Pipeable<Runtime<R>> {
/**

@@ -40,0 +41,0 @@ * The context used as initial for forks

3

src/Schedule.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type { Predicate } from "@effect/data/Predicate"

@@ -70,3 +71,3 @@ import type * as Cause from "@effect/io/Cause"

*/
export interface Schedule<Env, In, Out> extends Schedule.Variance<Env, In, Out> {
export interface Schedule<Env, In, Out> extends Schedule.Variance<Env, In, Out>, Pipeable<Schedule<Env, In, Out>> {
/**

@@ -73,0 +74,0 @@ * Initial State

5

src/Scope.ts

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

import type * as Context from "@effect/data/Context"
import type { Pipeable, PipeableOverride } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -41,3 +42,3 @@ import type * as ExecutionStrategy from "@effect/io/ExecutionStrategy"

*/
export interface Scope {
export interface Scope extends Pipeable<Scope> {
readonly [ScopeTypeId]: ScopeTypeId

@@ -59,3 +60,3 @@

*/
export interface CloseableScope extends Scope {
export interface CloseableScope extends PipeableOverride<Scope, CloseableScope> {
readonly [CloseableScopeTypeId]: CloseableScopeTypeId

@@ -62,0 +63,0 @@

5

src/ScopedCache.ts

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

import type * as Option from "@effect/data/Option"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Cache from "@effect/io/Cache"

@@ -29,3 +30,5 @@ import type * as Effect from "@effect/io/Effect"

*/
export interface ScopedCache<Key, Error, Value> extends ScopedCache.Variance<Key, Error, Value> {
export interface ScopedCache<Key, Error, Value>
extends ScopedCache.Variance<Key, Error, Value>, Pipeable<ScopedCache<Key, Error, Value>>
{
/**

@@ -32,0 +35,0 @@ * Retrieves the value associated with the specified key if it exists.

3

src/ScopedRef.ts

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

import type { LazyArg } from "@effect/data/Function"
import type { Pipeable } from "@effect/data/Pipeable"
import type * as Effect from "@effect/io/Effect"

@@ -33,3 +34,3 @@ import * as internal from "@effect/io/internal/scopedRef"

*/
export interface ScopedRef<A> extends ScopedRef.Variance<A> {
export interface ScopedRef<A> extends ScopedRef.Variance<A>, Pipeable<ScopedRef<A>> {
/** @internal */

@@ -36,0 +37,0 @@ readonly ref: Synchronized.Synchronized<readonly [Scope.Scope.Closeable, A]>

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

Config.d.ts.map

Sorry, the diff of this file is not supported yet

Config.js.map

Sorry, the diff of this file is not supported yet

Config/Provider.d.ts.map

Sorry, the diff of this file is not supported yet

Config/Provider.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

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

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

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/config.d.ts.map

Sorry, the diff of this file is not supported yet

internal/config.js.map

Sorry, the diff of this file is not supported yet

internal/configProvider.js.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/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.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/hub.js.map

Sorry, the diff of this file is not supported yet

internal/keyedPool.js.map

Sorry, the diff of this file is not supported yet

internal/layer.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/metric.js.map

Sorry, the diff of this file is not supported yet

internal/metric/boundaries.js.map

Sorry, the diff of this file is not supported yet

internal/metric/hook.js.map

Sorry, the diff of this file is not supported yet

internal/metric/key.js.map

Sorry, the diff of this file is not supported yet

internal/metric/keyType.d.ts.map

Sorry, the diff of this file is not supported yet

internal/metric/keyType.js.map

Sorry, the diff of this file is not supported yet

internal/metric/label.js.map

Sorry, the diff of this file is not supported yet

internal/metric/pair.js.map

Sorry, the diff of this file is not supported yet

internal/metric/polling.js.map

Sorry, the diff of this file is not supported yet

internal/metric/state.d.ts.map

Sorry, the diff of this file is not supported yet

internal/metric/state.js.map

Sorry, the diff of this file is not supported yet

internal/pool.js.map

Sorry, the diff of this file is not supported yet

internal/queue.js.map

Sorry, the diff of this file is not supported yet

internal/ref.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/scopedCache.js.map

Sorry, the diff of this file is not supported yet

internal/scopedRef.js.map

Sorry, the diff of this file is not supported yet

KeyedPool.d.ts.map

Sorry, the diff of this file is not supported yet

KeyedPool.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

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/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

mjs/Cause.mjs.map

Sorry, the diff of this file is not supported yet

mjs/Config.mjs.map

Sorry, the diff of this file is not supported yet

mjs/Config/Provider.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/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/FiberRef.mjs.map

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/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/config.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/config.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/configProvider.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/configProvider.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/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/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/keyedPool.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/keyedPool.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/layer.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/layer.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/metric.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/boundaries.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/boundaries.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/hook.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/hook.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/key.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/key.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/keyType.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/keyType.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/label.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/label.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/pair.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/pair.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/polling.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/polling.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/metric/state.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/metric/state.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/pool.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/pool.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/queue.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/queue.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/ref.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/ref.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/scopedCache.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/scopedCache.mjs.map

Sorry, the diff of this file is not supported yet

mjs/internal/scopedRef.mjs

Sorry, the diff of this file is not supported yet

mjs/internal/scopedRef.mjs.map

Sorry, the diff of this file is not supported yet

mjs/KeyedPool.mjs.map

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.map

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/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

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/State.mjs.map

Sorry, the diff of this file is not supported yet

mjs/Pool.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/Ref.mjs.map

Sorry, the diff of this file is not supported yet

mjs/RequestResolver.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/Scope.mjs.map

Sorry, the diff of this file is not supported yet

mjs/ScopedCache.mjs.map

Sorry, the diff of this file is not supported yet

mjs/ScopedRef.mjs.map

Sorry, the diff of this file is not supported yet

Pool.d.ts.map

Sorry, the diff of this file is not supported yet

Pool.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

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

RequestResolver.d.ts.map

Sorry, the diff of this file is not supported yet

RequestResolver.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

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

ScopedCache.d.ts.map

Sorry, the diff of this file is not supported yet

ScopedCache.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

src/internal/core.ts

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

src/internal/fiberRuntime.ts

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

src/internal/schedule.ts

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

SocketSocket SOC 2 Logo

Product

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

About

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc