@effect/io
Advanced tools
Comparing version 0.0.6 to 0.0.7
@@ -1,5 +0,1 @@ | ||
/** | ||
* @since 1.0.0 | ||
*/ | ||
import * as internal from "@effect/io/internal/fiberId"; | ||
import type * as Equal from "@fp-ts/data/Equal"; | ||
@@ -29,3 +25,3 @@ import type * as HashSet from "@fp-ts/data/HashSet"; | ||
readonly [FiberIdTypeId]: FiberIdTypeId; | ||
readonly op: internal.OP_NONE; | ||
readonly op: 0; | ||
} | ||
@@ -38,3 +34,3 @@ /** | ||
readonly [FiberIdTypeId]: FiberIdTypeId; | ||
readonly op: internal.OP_RUNTIME; | ||
readonly op: 1; | ||
readonly id: number; | ||
@@ -49,3 +45,3 @@ readonly startTimeMillis: number; | ||
readonly [FiberIdTypeId]: FiberIdTypeId; | ||
readonly op: internal.OP_COMPOSITE; | ||
readonly op: 2; | ||
readonly left: FiberId; | ||
@@ -52,0 +48,0 @@ readonly right: FiberId; |
@@ -6,3 +6,2 @@ /** | ||
import type * as RuntimeFlags from "@effect/io/Fiber/Runtime/Flags"; | ||
import * as internal from "@effect/io/internal/fiberStatus"; | ||
import type * as Equal from "@fp-ts/data/Equal"; | ||
@@ -29,3 +28,3 @@ /** | ||
export interface Done extends Equal.Equal { | ||
readonly op: internal.OP_DONE; | ||
readonly op: 0; | ||
readonly [FiberStatusTypeId]: FiberStatusTypeId; | ||
@@ -38,3 +37,3 @@ } | ||
export interface Running extends Equal.Equal { | ||
readonly op: internal.OP_RUNNING; | ||
readonly op: 1; | ||
readonly [FiberStatusTypeId]: FiberStatusTypeId; | ||
@@ -48,3 +47,3 @@ readonly runtimeFlags: RuntimeFlags.RuntimeFlags; | ||
export interface Suspended extends Equal.Equal { | ||
readonly op: internal.OP_SUSPENDED; | ||
readonly op: 2; | ||
readonly [FiberStatusTypeId]: FiberStatusTypeId; | ||
@@ -51,0 +50,0 @@ readonly runtimeFlags: RuntimeFlags.RuntimeFlags; |
@@ -7,3 +7,2 @@ /** | ||
import type * as FiberRef from "@effect/io/FiberRef"; | ||
import * as internal from "@effect/io/internal/fiberRefs"; | ||
import type * as HashSet from "@fp-ts/data/HashSet"; | ||
@@ -59,3 +58,3 @@ import type * as List from "@fp-ts/data/List"; | ||
*/ | ||
export declare const forkAs: (childId: FiberId.Runtime) => (self: FiberRefs) => internal.FiberRefsImpl; | ||
export declare const forkAs: (childId: FiberId.Runtime) => (self: FiberRefs) => FiberRefs; | ||
/** | ||
@@ -62,0 +61,0 @@ * Gets the value of the specified `FiberRef` in this collection of `FiberRef` |
@@ -7,3 +7,2 @@ /** | ||
import type * as FiberRefs from "@effect/io/FiberRefs"; | ||
import * as internal from "@effect/io/internal/fiberRefs/patch"; | ||
/** | ||
@@ -24,3 +23,3 @@ * A `FiberRefsPatch` captures the changes in `FiberRef` values made by a single | ||
export interface Empty { | ||
readonly op: internal.OP_EMPTY; | ||
readonly op: 0; | ||
} | ||
@@ -32,3 +31,3 @@ /** | ||
export interface Add { | ||
readonly op: internal.OP_ADD; | ||
readonly op: 1; | ||
readonly fiberRef: FiberRef.FiberRef<unknown>; | ||
@@ -42,3 +41,3 @@ readonly value: unknown; | ||
export interface Remove { | ||
readonly op: internal.OP_REMOVE; | ||
readonly op: 2; | ||
readonly fiberRef: FiberRef.FiberRef<unknown>; | ||
@@ -51,3 +50,3 @@ } | ||
export interface Update { | ||
readonly op: internal.OP_UPDATE; | ||
readonly op: 3; | ||
readonly fiberRef: FiberRef.FiberRef<unknown>; | ||
@@ -61,3 +60,3 @@ readonly patch: unknown; | ||
export interface AndThen { | ||
readonly op: internal.OP_AND_THEN; | ||
readonly op: 4; | ||
readonly first: FiberRefsPatch; | ||
@@ -64,0 +63,0 @@ readonly second: FiberRefsPatch; |
@@ -1,2 +0,2 @@ | ||
export { _continue as continue }; | ||
export {}; | ||
//# sourceMappingURL=decision.d.ts.map |
@@ -6,3 +6,3 @@ "use strict"; | ||
}); | ||
exports.isDone = exports.isContinue = exports.done = exports.continueWith = exports.continue = exports.OP_DONE = exports.OP_CONTINUE = void 0; | ||
exports.isDone = exports.isContinue = exports.done = exports.continueWith = exports._continue = exports.OP_DONE = exports.OP_CONTINUE = void 0; | ||
var Intervals = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Schedule/Intervals")); | ||
@@ -25,4 +25,4 @@ var List = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@fp-ts/data/List")); | ||
}; | ||
exports.continue = _continue; | ||
/** @internal */ | ||
exports._continue = _continue; | ||
const continueWith = interval => { | ||
@@ -29,0 +29,0 @@ return { |
@@ -1,2 +0,10 @@ | ||
export {}; | ||
import type * as Effect from "@effect/io/Effect"; | ||
export type EnforceNonEmptyRecord<R> = keyof R extends never ? never : R; | ||
export type MergeRecord<K, H> = { | ||
readonly [k in keyof K | keyof H]: k extends keyof K ? K[k] : k extends keyof H ? H[k] : never; | ||
} extends infer X ? X : never; | ||
export type NonEmptyArrayEffect = [Effect.Effect<any, any, any>, ...Array<Effect.Effect<any, any, any>>]; | ||
export type TupleA<T extends NonEmptyArrayEffect> = { | ||
[K in keyof T]: [T[K]] extends [Effect.Effect<any, any, infer A>] ? A : never; | ||
}; | ||
//# sourceMappingURL=types.d.ts.map |
{ | ||
"name": "@effect/io", | ||
"version": "0.0.6", | ||
"version": "0.0.7", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "repository": { |
@@ -1,5 +0,1 @@ | ||
/** | ||
* @since 1.0.0 | ||
*/ | ||
import * as internal from "@effect/io/internal/schedule/decision"; | ||
import type * as Interval from "@effect/io/Schedule/Interval"; | ||
@@ -17,3 +13,3 @@ import type * as Intervals from "@effect/io/Schedule/Intervals"; | ||
export interface Continue { | ||
readonly op: internal.OP_CONTINUE; | ||
readonly op: 0; | ||
readonly intervals: Intervals.Intervals; | ||
@@ -26,3 +22,3 @@ } | ||
export interface Done { | ||
readonly op: internal.OP_DONE; | ||
readonly op: 1; | ||
} | ||
@@ -29,0 +25,0 @@ declare const _continue: (intervals: Intervals.Intervals) => ScheduleDecision; |
@@ -14,3 +14,3 @@ "use strict"; | ||
const _continue = internal.continue; | ||
const _continue = internal._continue; | ||
exports.continue = _continue; | ||
@@ -17,0 +17,0 @@ /** |
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 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
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
3972854
66160