Context.Reference<Metadata<unknown, unknown>>Context reference containing metadata for the currently running schedule step.
Details
Repeat, retry, stream, and channel scheduling operations provide this service to effects run between schedule steps. The default value contains undefined input and output values, zero duration, and zeroed timing fields before any schedule step has produced metadata.
export const const CurrentMetadata: Context.Reference<
Metadata<unknown, unknown>
>
const CurrentMetadata: {
key: string;
Service: {
output: Output;
duration: Duration.Duration;
input: Input;
attempt: number;
start: number;
now: number;
elapsed: number;
elapsedSincePrevious: number;
};
defaultValue: () => Shape;
of: (this: void, self: Metadata<unknown, unknown>) => Metadata<unknown, unknown>;
context: (self: Metadata<unknown, unknown>) => Context.Context<never>;
use: (f: (service: Metadata<unknown, unknown>) => Effect<A, E, R>) => Effect<A, E, R>;
useSync: (f: (service: Metadata<unknown, unknown>) => A) => Effect<A, never, never>;
Identifier: Identifier;
stack: string | undefined;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
toString: () => string;
toJSON: () => unknown;
}
Context reference containing metadata for the currently running schedule step.
Details
Repeat, retry, stream, and channel scheduling operations provide this service
to effects run between schedule steps. The default value contains undefined
input and output values, zero duration, and zeroed timing fields before any
schedule step has produced metadata.
CurrentMetadata = import ContextContext.Reference<interface Metadata<Output = unknown, Input = unknown>Extended metadata that includes both input metadata and the output value from the schedule.
Metadata>("effect/Schedule/CurrentMetadata", {
defaultValue: LazyArg<{
input: undefined
output: undefined
duration: Duration.Duration
attempt: number
start: number
now: number
elapsed: number
elapsedSincePrevious: number
}>
import constantconstant({
input: undefinedinput: var undefinedundefined,
output: undefinedoutput: var undefinedundefined,
duration: Duration.Duration(property) duration: {
value: DurationValue;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
toString: () => string;
toJSON: () => unknown;
}
import DurationDuration.zero,
attempt: numberattempt: 0,
start: numberstart: 0,
now: numbernow: 0,
elapsed: numberelapsed: 0,
elapsedSincePrevious: numberelapsedSincePrevious: 0
})
})