@effect/io
Advanced tools
Comparing version 0.32.2 to 0.33.0
@@ -316,3 +316,3 @@ "use strict"; | ||
exports.parallelCollectionMake = parallelCollectionMake; | ||
const parallelCollectionCombine = (self, that) => new ParallelImpl(HashMap.reduceWithIndex(self.map, that.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), { | ||
const parallelCollectionCombine = (self, that) => new ParallelImpl(HashMap.reduce(self.map, that.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), { | ||
onNone: () => value, | ||
@@ -352,3 +352,3 @@ onSome: a => [...a, ...value] | ||
exports.sequentialCollectionMake = sequentialCollectionMake; | ||
const sequentialCollectionCombine = (self, that) => new SequentialImpl(HashMap.reduceWithIndex(that.map, self.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), { | ||
const sequentialCollectionCombine = (self, that) => new SequentialImpl(HashMap.reduce(that.map, self.map, (map, value, key) => HashMap.set(map, key, Option.match(HashMap.get(map, key), { | ||
onNone: () => [], | ||
@@ -355,0 +355,0 @@ onSome: a => [...a, ...value] |
@@ -12,26 +12,20 @@ "use strict"; | ||
const match = (options, sequential, unbounded, bounded) => { | ||
let effect; | ||
switch (options?.concurrency) { | ||
case undefined: | ||
{ | ||
effect = sequential(); | ||
break; | ||
return sequential(); | ||
} | ||
case "unbounded": | ||
{ | ||
effect = unbounded(); | ||
break; | ||
return unbounded(); | ||
} | ||
case "inherit": | ||
{ | ||
effect = core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? unbounded() : concurrency > 1 ? bounded(concurrency) : sequential()); | ||
break; | ||
return core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? unbounded() : concurrency > 1 ? bounded(concurrency) : sequential()); | ||
} | ||
default: | ||
{ | ||
effect = options.concurrency > 1 ? bounded(options.concurrency) : sequential(); | ||
break; | ||
return options.concurrency > 1 ? bounded(options.concurrency) : sequential(); | ||
} | ||
} | ||
return effect; | ||
}; | ||
@@ -41,28 +35,22 @@ /** @internal */ | ||
const matchSimple = (options, sequential, concurrent) => { | ||
let effect; | ||
switch (options?.concurrency) { | ||
case undefined: | ||
{ | ||
effect = sequential(); | ||
break; | ||
return sequential(); | ||
} | ||
case "unbounded": | ||
{ | ||
effect = concurrent(); | ||
break; | ||
return concurrent(); | ||
} | ||
case "inherit": | ||
{ | ||
effect = core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? concurrent() : concurrency > 1 ? concurrent() : sequential()); | ||
break; | ||
return core.fiberRefGetWith(core.currentConcurrency, concurrency => concurrency === "unbounded" ? concurrent() : concurrency > 1 ? concurrent() : sequential()); | ||
} | ||
default: | ||
{ | ||
effect = options.concurrency > 1 ? concurrent() : sequential(); | ||
break; | ||
return options.concurrency > 1 ? concurrent() : sequential(); | ||
} | ||
} | ||
return effect; | ||
}; | ||
exports.matchSimple = matchSimple; | ||
//# sourceMappingURL=concurrency.js.map |
@@ -12,3 +12,2 @@ "use strict"; | ||
var RA = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/ReadonlyArray")); | ||
var String = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/String")); | ||
var configError = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/configError")); | ||
@@ -78,3 +77,3 @@ function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); } | ||
{ | ||
const containsName = Option.contains(String.Equivalence)(patch.name)(RA.head(output)); | ||
const containsName = Option.contains(patch.name)(RA.head(output)); | ||
if (containsName) { | ||
@@ -81,0 +80,0 @@ output = RA.tailNonEmpty(output); |
@@ -375,5 +375,4 @@ "use strict"; | ||
const ignoreLogged = self => core.matchCauseEffect(self, { | ||
onFailure: cause => logCause(cause, { | ||
message: "An error was silently ignored because it is not anticipated to be useful", | ||
level: "Debug" | ||
onFailure: cause => logCause(cause, "Debug", { | ||
message: "An error was silently ignored because it is not anticipated to be useful" | ||
}), | ||
@@ -407,10 +406,10 @@ onSuccess: () => core.unit | ||
exports.iterate = iterate; | ||
const log = /*#__PURE__*/(0, _Function.dual)(args => typeof args[0] === "string", (message, options) => core.withFiberRuntime(fiberState => { | ||
fiberState.log(message, options?.cause ?? internalCause.empty, options?.level ? Option.some(LogLevel.fromLiteral(options.level)) : Option.none()); | ||
const log = (message, level, options) => core.withFiberRuntime(fiberState => { | ||
fiberState.log(message, options?.cause ?? internalCause.empty, level ? Option.some(LogLevel.fromLiteral(level)) : Option.none()); | ||
return core.unit; | ||
})); | ||
}); | ||
/* @internal */ | ||
exports.log = log; | ||
const logCause = /*#__PURE__*/(0, _Function.dual)(args => internalCause.isCause(args[0]), (cause, options) => core.withFiberRuntime(fiberState => { | ||
fiberState.log(options?.message ?? "", cause, options?.level ? Option.some(LogLevel.fromLiteral(options.level)) : Option.none()); | ||
const logCause = /*#__PURE__*/(0, _Function.dual)(args => internalCause.isCause(args[0]), (cause, level, options) => core.withFiberRuntime(fiberState => { | ||
fiberState.log(options?.message ?? "", cause, level ? Option.some(LogLevel.fromLiteral(level)) : Option.none()); | ||
return core.unit; | ||
@@ -420,6 +419,6 @@ })); | ||
exports.logCause = logCause; | ||
const withLog = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, message, options) => core.zipLeft(self, log(message, options))); | ||
const withLog = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, message, level, options) => core.zipLeft(self, log(message, level, options))); | ||
/* @internal */ | ||
exports.withLog = withLog; | ||
const withLogCause = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, options) => tapErrorCause(self, logCause(options))); | ||
const withLogCause = /*#__PURE__*/(0, _Function.dual)(args => core.isEffect(args[0]), (self, level, options) => tapErrorCause(self, logCause(level, options))); | ||
/* @internal */ | ||
@@ -773,3 +772,3 @@ exports.withLogCause = withLogCause; | ||
const span = tracer.span(name, parent, options?.context ?? Context.empty(), startTime); | ||
HashMap.forEachWithIndex(annotations, (value, key) => span.attribute(key, value)); | ||
HashMap.forEach(annotations, (value, key) => span.attribute(key, value)); | ||
Object.entries(options?.attributes ?? {}).forEach(([k, v]) => { | ||
@@ -776,0 +775,0 @@ span.attribute(k, v); |
@@ -47,3 +47,3 @@ "use strict"; | ||
exports.RuntimeFiberTypeId = RuntimeFiberTypeId; | ||
const Order = /*#__PURE__*/order.contramap(fiber => [fiber.id().startTimeMillis, fiber.id().id])( /*#__PURE__*/order.tuple(number.Order, number.Order)); | ||
const Order = /*#__PURE__*/order.mapInput(fiber => [fiber.id().startTimeMillis, fiber.id().id])( /*#__PURE__*/order.tuple(number.Order, number.Order)); | ||
/** @internal */ | ||
@@ -50,0 +50,0 @@ exports.Order = Order; |
@@ -9,3 +9,3 @@ "use strict"; | ||
var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context")); | ||
var PCGRandom = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Random")); | ||
var DeterministicRandom = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/DeterministicRandom")); | ||
var core = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/internal/core")); | ||
@@ -28,3 +28,3 @@ 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); } | ||
this[_a] = RandomTypeId; | ||
this.PRNG = new PCGRandom.PCGRandom(seed); | ||
this.PRNG = new DeterministicRandom.PCGRandom(seed); | ||
} | ||
@@ -31,0 +31,0 @@ next() { |
@@ -166,5 +166,3 @@ "use strict"; | ||
warningStart() { | ||
return synchronized.updateSomeEffect(this.warningState, data => WarningData.isStart(data) ? Option.some(core.map(fiber => WarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(effect.log(warning, { | ||
level: "Warning" | ||
}))))))) : Option.none()); | ||
return synchronized.updateSomeEffect(this.warningState, data => WarningData.isStart(data) ? Option.some(core.map(fiber => WarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(effect.log(warning, "Warning"))))))) : Option.none()); | ||
} | ||
@@ -205,5 +203,3 @@ /** | ||
if (SuspendedWarningData.isStart(suspendedWarningData)) { | ||
return Option.some(core.map(fiber => SuspendedWarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(core.zipRight(ref.set(this.suspendedWarningState, SuspendedWarningData.done))(effect.log(suspendedWarning, { | ||
level: "Warning" | ||
})))))))); | ||
return Option.some(core.map(fiber => SuspendedWarningData.pending(fiber))(fiberRuntime.fork(core.interruptible(this.live.provide(effect.delay(Duration.seconds(5))(core.zipRight(ref.set(this.suspendedWarningState, SuspendedWarningData.done))(effect.log(suspendedWarning, "Warning")))))))); | ||
} | ||
@@ -244,3 +240,3 @@ return Option.none(); | ||
const end = f(data.instant); | ||
const sorted = Chunk.sort(Order.contramap(_ => _[0])(number.Order))(data.sleeps); | ||
const sorted = Chunk.sort(Order.mapInput(_ => _[0])(number.Order))(data.sleeps); | ||
if (Chunk.isNonEmpty(sorted)) { | ||
@@ -247,0 +243,0 @@ const [instant, deferred] = Chunk.headNonEmpty(sorted); |
@@ -557,4 +557,4 @@ /** | ||
export declare const tap: { | ||
<ROut, RIn2, E2, X>(f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>): <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>; | ||
<RIn, E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>; | ||
<ROut, XR extends ROut, RIn2, E2, X>(f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>): <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut>; | ||
<RIn, E, ROut, XR extends ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>; | ||
}; | ||
@@ -568,4 +568,4 @@ /** | ||
export declare const tapError: { | ||
<E, RIn2, E2, X>(f: (e: E) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>; | ||
<RIn, E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (e: E) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>; | ||
<E, XE extends E, RIn2, E2, X>(f: (e: XE) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>; | ||
<RIn, E, XE extends E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (e: XE) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>; | ||
}; | ||
@@ -579,4 +579,4 @@ /** | ||
export declare const tapErrorCause: { | ||
<E, RIn2, E2, X>(f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>; | ||
<RIn, E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>; | ||
<E, XE extends E, RIn2, E2, X>(f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut>; | ||
<RIn, E, XE extends E, ROut, RIn2, E2, X>(self: Layer<RIn, E, ROut>, f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X>): Layer<RIn | RIn2, E | E2, ROut>; | ||
}; | ||
@@ -583,0 +583,0 @@ /** |
@@ -84,3 +84,3 @@ "use strict"; | ||
exports.locally = locally; | ||
const Order = /*#__PURE__*/order.contramap(level => level.ordinal)(number.Order); | ||
const Order = /*#__PURE__*/order.mapInput(level => level.ordinal)(number.Order); | ||
/** | ||
@@ -87,0 +87,0 @@ * @since 1.0.0 |
{ | ||
"name": "@effect/io", | ||
"version": "0.32.2", | ||
"version": "0.33.0", | ||
"license": "MIT", | ||
@@ -10,3 +10,3 @@ "repository": { | ||
"dependencies": { | ||
"@effect/data": "^0.14.1" | ||
"@effect/data": "^0.15.0" | ||
}, | ||
@@ -13,0 +13,0 @@ "publishConfig": { |
@@ -891,4 +891,4 @@ /** | ||
export declare const tapOutput: { | ||
<Out, Env2, X>(f: (out: Out) => Effect.Effect<Env2, never, X>): <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>; | ||
<Env, In, Out, Env2, X>(self: Schedule<Env, In, Out>, f: (out: Out) => Effect.Effect<Env2, never, X>): Schedule<Env | Env2, In, Out>; | ||
<Out, XO extends Out, Env2, X>(f: (out: XO) => Effect.Effect<Env2, never, X>): <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out>; | ||
<Env, In, Out, XO extends Out, Env2, X>(self: Schedule<Env, In, Out>, f: (out: XO) => Effect.Effect<Env2, never, X>): Schedule<Env | Env2, In, Out>; | ||
}; | ||
@@ -895,0 +895,0 @@ /** |
@@ -380,3 +380,3 @@ import * as Either from "@effect/data/Either" | ||
): ParallelCollection<R | R2> => | ||
new ParallelImpl(HashMap.reduceWithIndex(self.map, that.map, (map, value, key) => | ||
new ParallelImpl(HashMap.reduce(self.map, that.map, (map, value, key) => | ||
HashMap.set( | ||
@@ -447,3 +447,3 @@ map, | ||
): SequentialCollection<R | R2> => | ||
new SequentialImpl(HashMap.reduceWithIndex(that.map, self.map, (map, value, key) => | ||
new SequentialImpl(HashMap.reduce(that.map, self.map, (map, value, key) => | ||
HashMap.set( | ||
@@ -450,0 +450,0 @@ map, |
@@ -21,14 +21,11 @@ import type { Concurrency } from "@effect/io/Concurrency" | ||
) => { | ||
let effect: Effect<R, E, A> | ||
switch (options?.concurrency) { | ||
case undefined: { | ||
effect = sequential() | ||
break | ||
return sequential() | ||
} | ||
case "unbounded": { | ||
effect = unbounded() | ||
break | ||
return unbounded() | ||
} | ||
case "inherit": { | ||
effect = core.fiberRefGetWith( | ||
return core.fiberRefGetWith( | ||
core.currentConcurrency, | ||
@@ -42,12 +39,9 @@ (concurrency) => | ||
) | ||
break | ||
} | ||
default: { | ||
effect = options!.concurrency > 1 ? | ||
return options!.concurrency > 1 ? | ||
bounded(options!.concurrency) : | ||
sequential() | ||
break | ||
} | ||
} | ||
return effect | ||
} | ||
@@ -69,14 +63,11 @@ | ||
) => { | ||
let effect: Effect<R, E, A> | ||
switch (options?.concurrency) { | ||
case undefined: { | ||
effect = sequential() | ||
break | ||
return sequential() | ||
} | ||
case "unbounded": { | ||
effect = concurrent() | ||
break | ||
return concurrent() | ||
} | ||
case "inherit": { | ||
effect = core.fiberRefGetWith( | ||
return core.fiberRefGetWith( | ||
core.currentConcurrency, | ||
@@ -90,11 +81,7 @@ (concurrency) => | ||
) | ||
break | ||
} | ||
default: { | ||
effect = options!.concurrency > 1 ? concurrent() : sequential() | ||
break | ||
return options!.concurrency > 1 ? concurrent() : sequential() | ||
} | ||
} | ||
return effect | ||
} |
@@ -6,3 +6,2 @@ import * as Either from "@effect/data/Either" | ||
import * as RA from "@effect/data/ReadonlyArray" | ||
import * as String from "@effect/data/String" | ||
import type * as ConfigError from "@effect/io/Config/Error" | ||
@@ -83,3 +82,3 @@ import type * as PathPatch from "@effect/io/Config/Provider/PathPatch" | ||
RA.head(output), | ||
Option.contains(String.Equivalence)(patch.name) | ||
Option.contains(patch.name) | ||
) | ||
@@ -86,0 +85,0 @@ if (containsName) { |
@@ -52,3 +52,3 @@ import * as Either from "@effect/data/Either" | ||
order.tuple<readonly [order.Order<number>, order.Order<number>]>(number.Order, number.Order), | ||
order.contramap((fiber: Fiber.RuntimeFiber<unknown, unknown>) => | ||
order.mapInput((fiber: Fiber.RuntimeFiber<unknown, unknown>) => | ||
[ | ||
@@ -55,0 +55,0 @@ (fiber.id() as FiberId.Runtime).startTimeMillis, |
@@ -982,8 +982,8 @@ import * as Context from "@effect/data/Context" | ||
export const tap = dual< | ||
<ROut, RIn2, E2, X>( | ||
f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X> | ||
<ROut, XR extends ROut, RIn2, E2, X>( | ||
f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X> | ||
) => <RIn, E>(self: Layer.Layer<RIn, E, ROut>) => Layer.Layer<RIn | RIn2, E | E2, ROut>, | ||
<RIn, E, ROut, RIn2, E2, X>( | ||
<RIn, E, ROut, XR extends ROut, RIn2, E2, X>( | ||
self: Layer.Layer<RIn, E, ROut>, | ||
f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X> | ||
f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X> | ||
) => Layer.Layer<RIn | RIn2, E | E2, ROut> | ||
@@ -994,8 +994,8 @@ >(2, (self, f) => flatMap(self, (context) => fromEffectContext(core.as(f(context), context)))) | ||
export const tapError = dual< | ||
<E, RIn2, E2, X>( | ||
f: (e: E) => Effect.Effect<RIn2, E2, X> | ||
<E, XE extends E, RIn2, E2, X>( | ||
f: (e: XE) => Effect.Effect<RIn2, E2, X> | ||
) => <RIn, ROut>(self: Layer.Layer<RIn, E, ROut>) => Layer.Layer<RIn | RIn2, E | E2, ROut>, | ||
<RIn, E, ROut, RIn2, E2, X>( | ||
<RIn, E, XE extends E, ROut, RIn2, E2, X>( | ||
self: Layer.Layer<RIn, E, ROut>, | ||
f: (e: E) => Effect.Effect<RIn2, E2, X> | ||
f: (e: XE) => Effect.Effect<RIn2, E2, X> | ||
) => Layer.Layer<RIn | RIn2, E | E2, ROut> | ||
@@ -1005,3 +1005,3 @@ >(2, (self, f) => | ||
self, | ||
(e) => fromEffectContext(core.flatMap(f(e), () => core.fail(e))) | ||
(e) => fromEffectContext(core.flatMap(f(e as any), () => core.fail(e))) | ||
)) | ||
@@ -1011,8 +1011,8 @@ | ||
export const tapErrorCause = dual< | ||
<E, RIn2, E2, X>( | ||
f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X> | ||
<E, XE extends E, RIn2, E2, X>( | ||
f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X> | ||
) => <RIn, ROut>(self: Layer.Layer<RIn, E, ROut>) => Layer.Layer<RIn | RIn2, E | E2, ROut>, | ||
<RIn, E, ROut, RIn2, E2, X>( | ||
<RIn, E, XE extends E, ROut, RIn2, E2, X>( | ||
self: Layer.Layer<RIn, E, ROut>, | ||
f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X> | ||
f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X> | ||
) => Layer.Layer<RIn | RIn2, E | E2, ROut> | ||
@@ -1022,3 +1022,3 @@ >(2, (self, f) => | ||
self, | ||
(cause) => fromEffectContext(core.flatMap(f(cause), () => core.failCause(cause))) | ||
(cause) => fromEffectContext(core.flatMap(f(cause as any), () => core.failCause(cause))) | ||
)) | ||
@@ -1025,0 +1025,0 @@ |
import * as Chunk from "@effect/data/Chunk" | ||
import * as Context from "@effect/data/Context" | ||
import * as DeterministicRandom from "@effect/data/DeterministicRandom" | ||
import { pipe } from "@effect/data/Function" | ||
import * as PCGRandom from "@effect/data/Random" | ||
import type * as Effect from "@effect/io/Effect" | ||
@@ -23,6 +23,6 @@ import * as core from "@effect/io/internal/core" | ||
readonly PRNG: PCGRandom.PCGRandom | ||
readonly PRNG: DeterministicRandom.PCGRandom | ||
constructor(readonly seed: number) { | ||
this.PRNG = new PCGRandom.PCGRandom(seed) | ||
this.PRNG = new DeterministicRandom.PCGRandom(seed) | ||
} | ||
@@ -29,0 +29,0 @@ |
@@ -261,3 +261,3 @@ import * as Chunk from "@effect/data/Chunk" | ||
this.live.provide( | ||
pipe(effect.log(warning, { level: "Warning" }), effect.delay(Duration.seconds(5))) | ||
pipe(effect.log(warning, "Warning"), effect.delay(Duration.seconds(5))) | ||
), | ||
@@ -331,3 +331,3 @@ core.interruptible, | ||
pipe( | ||
effect.log(suspendedWarning, { level: "Warning" }), | ||
effect.log(suspendedWarning, "Warning"), | ||
core.zipRight(ref.set(this.suspendedWarningState, SuspendedWarningData.done)), | ||
@@ -370,3 +370,3 @@ effect.delay(Duration.seconds(5)) | ||
data.sleeps, | ||
Chunk.sort<readonly [number, Deferred<never, void>]>(pipe(number.Order, Order.contramap((_) => _[0]))) | ||
Chunk.sort<readonly [number, Deferred<never, void>]>(pipe(number.Order, Order.mapInput((_) => _[0]))) | ||
) | ||
@@ -373,0 +373,0 @@ if (Chunk.isNonEmpty(sorted)) { |
@@ -716,8 +716,8 @@ /** | ||
export const tap: { | ||
<ROut, RIn2, E2, X>( | ||
f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X> | ||
<ROut, XR extends ROut, RIn2, E2, X>( | ||
f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X> | ||
): <RIn, E>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E2 | E, ROut> | ||
<RIn, E, ROut, RIn2, E2, X>( | ||
<RIn, E, ROut, XR extends ROut, RIn2, E2, X>( | ||
self: Layer<RIn, E, ROut>, | ||
f: (context: Context.Context<ROut>) => Effect.Effect<RIn2, E2, X> | ||
f: (context: Context.Context<XR>) => Effect.Effect<RIn2, E2, X> | ||
): Layer<RIn | RIn2, E | E2, ROut> | ||
@@ -733,8 +733,8 @@ } = internal.tap | ||
export const tapError: { | ||
<E, RIn2, E2, X>( | ||
f: (e: E) => Effect.Effect<RIn2, E2, X> | ||
<E, XE extends E, RIn2, E2, X>( | ||
f: (e: XE) => Effect.Effect<RIn2, E2, X> | ||
): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut> | ||
<RIn, E, ROut, RIn2, E2, X>( | ||
<RIn, E, XE extends E, ROut, RIn2, E2, X>( | ||
self: Layer<RIn, E, ROut>, | ||
f: (e: E) => Effect.Effect<RIn2, E2, X> | ||
f: (e: XE) => Effect.Effect<RIn2, E2, X> | ||
): Layer<RIn | RIn2, E | E2, ROut> | ||
@@ -750,8 +750,8 @@ } = internal.tapError | ||
export const tapErrorCause: { | ||
<E, RIn2, E2, X>( | ||
f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X> | ||
<E, XE extends E, RIn2, E2, X>( | ||
f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X> | ||
): <RIn, ROut>(self: Layer<RIn, E, ROut>) => Layer<RIn2 | RIn, E | E2, ROut> | ||
<RIn, E, ROut, RIn2, E2, X>( | ||
<RIn, E, XE extends E, ROut, RIn2, E2, X>( | ||
self: Layer<RIn, E, ROut>, | ||
f: (cause: Cause.Cause<E>) => Effect.Effect<RIn2, E2, X> | ||
f: (cause: Cause.Cause<XE>) => Effect.Effect<RIn2, E2, X> | ||
): Layer<RIn | RIn2, E | E2, ROut> | ||
@@ -758,0 +758,0 @@ } = internal.tapErrorCause |
@@ -194,3 +194,3 @@ /** | ||
number.Order, | ||
order.contramap((level: LogLevel) => level.ordinal) | ||
order.mapInput((level: LogLevel) => level.ordinal) | ||
) | ||
@@ -197,0 +197,0 @@ |
@@ -1145,8 +1145,8 @@ /** | ||
export const tapOutput: { | ||
<Out, Env2, X>( | ||
f: (out: Out) => Effect.Effect<Env2, never, X> | ||
<Out, XO extends Out, Env2, X>( | ||
f: (out: XO) => Effect.Effect<Env2, never, X> | ||
): <Env, In>(self: Schedule<Env, In, Out>) => Schedule<Env2 | Env, In, Out> | ||
<Env, In, Out, Env2, X>( | ||
<Env, In, Out, XO extends Out, Env2, X>( | ||
self: Schedule<Env, In, Out>, | ||
f: (out: Out) => Effect.Effect<Env2, never, X> | ||
f: (out: XO) => Effect.Effect<Env2, never, X> | ||
): Schedule<Env | Env2, In, Out> | ||
@@ -1153,0 +1153,0 @@ } = internal.tapOutput |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
6373472
113743
+ Added@effect/data@0.15.1(transitive)
- Removed@effect/data@0.14.3(transitive)
Updated@effect/data@^0.15.0