Lorem Ipsum MCP Server
by ssv445
Runtime.ts•16.4 kB
/**
* @since 2.0.0
*/
import type { Cause } from "./Cause.js"
import type * as Context from "./Context.js"
import type * as Effect from "./Effect.js"
import type * as Exit from "./Exit.js"
import type * as Fiber from "./Fiber.js"
import type * as FiberId from "./FiberId.js"
import type * as FiberRef from "./FiberRef.js"
import type * as FiberRefs from "./FiberRefs.js"
import type { Inspectable } from "./Inspectable.js"
import * as internal from "./internal/runtime.js"
import type { Pipeable } from "./Pipeable.js"
import type * as RuntimeFlags from "./RuntimeFlags.js"
import type { Scheduler } from "./Scheduler.js"
import type { Scope } from "./Scope.js"
/**
* @since 2.0.0
* @category models
*/
export interface AsyncFiberException<out A, out E = never> {
readonly _tag: "AsyncFiberException"
readonly fiber: Fiber.RuntimeFiber<A, E>
}
/**
* @since 2.0.0
* @category models
*/
export interface Cancel<out A, out E = never> {
(fiberId?: FiberId.FiberId, options?: RunCallbackOptions<A, E> | undefined): void
}
/**
* @since 2.0.0
* @category models
*/
export interface Runtime<in R> extends Pipeable {
/**
* The context used as initial for forks
*/
readonly context: Context.Context<R>
/**
* The runtime flags used as initial for forks
*/
readonly runtimeFlags: RuntimeFlags.RuntimeFlags
/**
* The fiber references used as initial for forks
*/
readonly fiberRefs: FiberRefs.FiberRefs
}
/**
* @since 3.12.0
*/
export declare namespace Runtime {
/**
* @since 3.12.0
* @category Type Extractors
*/
export type Context<T extends Runtime<never>> = [T] extends [Runtime<infer R>] ? R : never
}
/**
* @since 2.0.0
* @category models
*/
export interface RunForkOptions {
readonly scheduler?: Scheduler | undefined
readonly updateRefs?: ((refs: FiberRefs.FiberRefs, fiberId: FiberId.Runtime) => FiberRefs.FiberRefs) | undefined
readonly immediate?: boolean
readonly scope?: Scope
}
/**
* Executes the effect using the provided Scheduler or using the global
* Scheduler if not provided
*
* @since 2.0.0
* @category execution
*/
export const runFork: {
/**
* Executes the effect using the provided Scheduler or using the global
* Scheduler if not provided
*
* @since 2.0.0
* @category execution
*/
<R>(runtime: Runtime<R>): <A, E>(effect: Effect.Effect<A, E, R>, options?: RunForkOptions | undefined) => Fiber.RuntimeFiber<A, E>
/**
* Executes the effect using the provided Scheduler or using the global
* Scheduler if not provided
*
* @since 2.0.0
* @category execution
*/
<R, A, E>(
runtime: Runtime<R>,
effect: Effect.Effect<A, E, R>,
options?: RunForkOptions | undefined
): Fiber.RuntimeFiber<A, E>
} = internal.unsafeFork
/**
* Executes the effect synchronously returning the exit.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
export const runSyncExit: {
/**
* Executes the effect synchronously returning the exit.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<A, E, R>(runtime: Runtime<R>, effect: Effect.Effect<A, E, R>): Exit.Exit<A, E>
/**
* Executes the effect synchronously returning the exit.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R>(runtime: Runtime<R>): <A, E>(effect: Effect.Effect<A, E, R>) => Exit.Exit<A, E>
} = internal.unsafeRunSyncExit
/**
* Executes the effect synchronously throwing in case of errors or async boundaries.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
export const runSync: {
/**
* Executes the effect synchronously throwing in case of errors or async boundaries.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<A, E, R>(runtime: Runtime<R>, effect: Effect.Effect<A, E, R>): A
/**
* Executes the effect synchronously throwing in case of errors or async boundaries.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R>(runtime: Runtime<R>): <A, E>(effect: Effect.Effect<A, E, R>) => A
} = internal.unsafeRunSync
/**
* @since 2.0.0
* @category models
*/
export interface RunCallbackOptions<in A, in E = never> extends RunForkOptions {
readonly onExit?: ((exit: Exit.Exit<A, E>) => void) | undefined
}
/**
* Executes the effect asynchronously, eventually passing the exit value to
* the specified callback.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
export const runCallback: {
/**
* Executes the effect asynchronously, eventually passing the exit value to
* the specified callback.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R>(runtime: Runtime<R>): <A, E>(
effect: Effect.Effect<A, E, R>,
options?: RunCallbackOptions<A, E> | undefined
) => (fiberId?: FiberId.FiberId, options?: RunCallbackOptions<A, E> | undefined) => void
/**
* Executes the effect asynchronously, eventually passing the exit value to
* the specified callback.
*
* This method is effectful and should only be invoked at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R, A, E>(
runtime: Runtime<R>,
effect: Effect.Effect<A, E, R>,
options?: RunCallbackOptions<A, E> | undefined
): (fiberId?: FiberId.FiberId, options?: RunCallbackOptions<A, E> | undefined) => void
} = internal.unsafeRunCallback
/**
* Runs the `Effect`, returning a JavaScript `Promise` that will be resolved
* with the value of the effect once the effect has been executed, or will be
* rejected with the first error or exception throw by the effect.
*
* This method is effectful and should only be used at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
export const runPromise: {
/**
* Runs the `Effect`, returning a JavaScript `Promise` that will be resolved
* with the value of the effect once the effect has been executed, or will be
* rejected with the first error or exception throw by the effect.
*
* This method is effectful and should only be used at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R>(runtime: Runtime<R>): <A, E>(effect: Effect.Effect<A, E, R>, options?: { readonly signal?: AbortSignal } | undefined) => Promise<A>
/**
* Runs the `Effect`, returning a JavaScript `Promise` that will be resolved
* with the value of the effect once the effect has been executed, or will be
* rejected with the first error or exception throw by the effect.
*
* This method is effectful and should only be used at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R, A, E>(
runtime: Runtime<R>,
effect: Effect.Effect<A, E, R>,
options?: { readonly signal?: AbortSignal } | undefined
): Promise<A>
} = internal.unsafeRunPromise
/**
* Runs the `Effect`, returning a JavaScript `Promise` that will be resolved
* with the `Exit` state of the effect once the effect has been executed.
*
* This method is effectful and should only be used at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
export const runPromiseExit: {
/**
* Runs the `Effect`, returning a JavaScript `Promise` that will be resolved
* with the `Exit` state of the effect once the effect has been executed.
*
* This method is effectful and should only be used at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R>(runtime: Runtime<R>): <A, E>(
effect: Effect.Effect<A, E, R>,
options?: { readonly signal?: AbortSignal } | undefined
) => Promise<Exit.Exit<A, E>>
/**
* Runs the `Effect`, returning a JavaScript `Promise` that will be resolved
* with the `Exit` state of the effect once the effect has been executed.
*
* This method is effectful and should only be used at the edges of your
* program.
*
* @since 2.0.0
* @category execution
*/
<R, A, E>(
runtime: Runtime<R>,
effect: Effect.Effect<A, E, R>,
options?: { readonly signal?: AbortSignal } | undefined
): Promise<Exit.Exit<A, E>>
} = internal.unsafeRunPromiseExit
/**
* @since 2.0.0
* @category constructors
*/
export const defaultRuntime: Runtime<never> = internal.defaultRuntime
/**
* @since 2.0.0
* @category constructors
*/
export const defaultRuntimeFlags: RuntimeFlags.RuntimeFlags = internal.defaultRuntimeFlags
/**
* @since 2.0.0
* @category constructors
*/
export const make: <R>(
options: {
readonly context: Context.Context<R>
readonly runtimeFlags: RuntimeFlags.RuntimeFlags
readonly fiberRefs: FiberRefs.FiberRefs
}
) => Runtime<R> = internal.make
/**
* @since 2.0.0
* @category symbols
*/
export const FiberFailureId = Symbol.for("effect/Runtime/FiberFailure")
/**
* @since 2.0.0
* @category symbols
*/
export type FiberFailureId = typeof FiberFailureId
/**
* @since 2.0.0
* @category symbols
*/
export const FiberFailureCauseId: unique symbol = internal.FiberFailureCauseId
/**
* @since 2.0.0
* @category exports
*/
export type FiberFailureCauseId = typeof FiberFailureCauseId
/**
* @since 2.0.0
* @category models
*/
export interface FiberFailure extends Error, Inspectable {
readonly [FiberFailureId]: FiberFailureId
readonly [FiberFailureCauseId]: Cause<unknown>
}
/**
* @since 2.0.0
* @category guards
*/
export const isAsyncFiberException: (u: unknown) => u is AsyncFiberException<unknown, unknown> =
internal.isAsyncFiberException
/**
* @since 2.0.0
* @category guards
*/
export const isFiberFailure: (u: unknown) => u is FiberFailure = internal.isFiberFailure
/**
* @since 2.0.0
* @category constructors
*/
export const makeFiberFailure: <E>(cause: Cause<E>) => FiberFailure = internal.fiberFailure
/**
* @since 2.0.0
* @category runtime flags
*/
export const updateRuntimeFlags: {
/**
* @since 2.0.0
* @category runtime flags
*/
(f: (flags: RuntimeFlags.RuntimeFlags) => RuntimeFlags.RuntimeFlags): <R>(self: Runtime<R>) => Runtime<R>
/**
* @since 2.0.0
* @category runtime flags
*/
<R>(
self: Runtime<R>,
f: (flags: RuntimeFlags.RuntimeFlags) => RuntimeFlags.RuntimeFlags
): Runtime<R>
} = internal.updateRuntimeFlags
/**
* @since 2.0.0
* @category runtime flags
*/
export const enableRuntimeFlag: {
/**
* @since 2.0.0
* @category runtime flags
*/
(flag: RuntimeFlags.RuntimeFlag): <R>(self: Runtime<R>) => Runtime<R>
/**
* @since 2.0.0
* @category runtime flags
*/
<R>(self: Runtime<R>, flag: RuntimeFlags.RuntimeFlag): Runtime<R>
} = internal.enableRuntimeFlag
/**
* @since 2.0.0
* @category runtime flags
*/
export const disableRuntimeFlag: {
/**
* @since 2.0.0
* @category runtime flags
*/
(flag: RuntimeFlags.RuntimeFlag): <R>(self: Runtime<R>) => Runtime<R>
/**
* @since 2.0.0
* @category runtime flags
*/
<R>(self: Runtime<R>, flag: RuntimeFlags.RuntimeFlag): Runtime<R>
} = internal.disableRuntimeFlag
/**
* @since 2.0.0
* @category context
*/
export const updateContext: {
/**
* @since 2.0.0
* @category context
*/
<R, R2>(f: (context: Context.Context<R>) => Context.Context<R2>): (self: Runtime<R>) => Runtime<R2>
/**
* @since 2.0.0
* @category context
*/
<R, R2>(self: Runtime<R>, f: (context: Context.Context<R>) => Context.Context<R2>): Runtime<R2>
} = internal.updateContext
/**
* @since 2.0.0
* @category context
* @example
* ```ts
* import { Context, Runtime } from "effect"
*
* class Name extends Context.Tag("Name")<Name, string>() {}
*
* const runtime: Runtime.Runtime<Name> = Runtime.defaultRuntime.pipe(
* Runtime.provideService(Name, "John")
* )
* ```
*/
export const provideService: {
/**
* @since 2.0.0
* @category context
* @example
* ```ts
* import { Context, Runtime } from "effect"
*
* class Name extends Context.Tag("Name")<Name, string>() {}
*
* const runtime: Runtime.Runtime<Name> = Runtime.defaultRuntime.pipe(
* Runtime.provideService(Name, "John")
* )
* ```
*/
<I, S>(tag: Context.Tag<I, S>, service: S): <R>(self: Runtime<R>) => Runtime<I | R>
/**
* @since 2.0.0
* @category context
* @example
* ```ts
* import { Context, Runtime } from "effect"
*
* class Name extends Context.Tag("Name")<Name, string>() {}
*
* const runtime: Runtime.Runtime<Name> = Runtime.defaultRuntime.pipe(
* Runtime.provideService(Name, "John")
* )
* ```
*/
<R, I, S>(self: Runtime<R>, tag: Context.Tag<I, S>, service: S): Runtime<R | I>
} = internal.provideService
/**
* @since 2.0.0
* @category fiber refs
*/
export const updateFiberRefs: {
/**
* @since 2.0.0
* @category fiber refs
*/
(f: (fiberRefs: FiberRefs.FiberRefs) => FiberRefs.FiberRefs): <R>(self: Runtime<R>) => Runtime<R>
/**
* @since 2.0.0
* @category fiber refs
*/
<R>(
self: Runtime<R>,
f: (fiberRefs: FiberRefs.FiberRefs) => FiberRefs.FiberRefs
): Runtime<R>
} = internal.updateFiberRefs
/**
* @since 2.0.0
* @category fiber refs
* @example
* ```ts
* import { Effect, FiberRef, Runtime } from "effect"
*
* const ref = FiberRef.unsafeMake(0)
*
* const updatedRuntime = Runtime.defaultRuntime.pipe(
* Runtime.setFiberRef(ref, 1)
* )
*
* // returns 1
* const result = Runtime.runSync(updatedRuntime)(FiberRef.get(ref))
* ```
*/
export const setFiberRef: {
/**
* @since 2.0.0
* @category fiber refs
* @example
* ```ts
* import { Effect, FiberRef, Runtime } from "effect"
*
* const ref = FiberRef.unsafeMake(0)
*
* const updatedRuntime = Runtime.defaultRuntime.pipe(
* Runtime.setFiberRef(ref, 1)
* )
*
* // returns 1
* const result = Runtime.runSync(updatedRuntime)(FiberRef.get(ref))
* ```
*/
<A>(fiberRef: FiberRef.FiberRef<A>, value: A): <R>(self: Runtime<R>) => Runtime<R>
/**
* @since 2.0.0
* @category fiber refs
* @example
* ```ts
* import { Effect, FiberRef, Runtime } from "effect"
*
* const ref = FiberRef.unsafeMake(0)
*
* const updatedRuntime = Runtime.defaultRuntime.pipe(
* Runtime.setFiberRef(ref, 1)
* )
*
* // returns 1
* const result = Runtime.runSync(updatedRuntime)(FiberRef.get(ref))
* ```
*/
<R, A>(self: Runtime<R>, fiberRef: FiberRef.FiberRef<A>, value: A): Runtime<R>
} = internal.setFiberRef
/**
* @since 2.0.0
* @category fiber refs
* @example
* ```ts
* import { Effect, FiberRef, Runtime } from "effect"
*
* const ref = FiberRef.unsafeMake(0)
*
* const updatedRuntime = Runtime.defaultRuntime.pipe(
* Runtime.setFiberRef(ref, 1),
* Runtime.deleteFiberRef(ref)
* )
*
* // returns 0
* const result = Runtime.runSync(updatedRuntime)(FiberRef.get(ref))
* ```
*/
export const deleteFiberRef: {
/**
* @since 2.0.0
* @category fiber refs
* @example
* ```ts
* import { Effect, FiberRef, Runtime } from "effect"
*
* const ref = FiberRef.unsafeMake(0)
*
* const updatedRuntime = Runtime.defaultRuntime.pipe(
* Runtime.setFiberRef(ref, 1),
* Runtime.deleteFiberRef(ref)
* )
*
* // returns 0
* const result = Runtime.runSync(updatedRuntime)(FiberRef.get(ref))
* ```
*/
<A>(fiberRef: FiberRef.FiberRef<A>): <R>(self: Runtime<R>) => Runtime<R>
/**
* @since 2.0.0
* @category fiber refs
* @example
* ```ts
* import { Effect, FiberRef, Runtime } from "effect"
*
* const ref = FiberRef.unsafeMake(0)
*
* const updatedRuntime = Runtime.defaultRuntime.pipe(
* Runtime.setFiberRef(ref, 1),
* Runtime.deleteFiberRef(ref)
* )
*
* // returns 0
* const result = Runtime.runSync(updatedRuntime)(FiberRef.get(ref))
* ```
*/
<R, A>(self: Runtime<R>, fiberRef: FiberRef.FiberRef<A>): Runtime<R>
} = internal.deleteFiberRef
Latest Blog Posts
- MCP Moves to the Linux Foundation: Neutral Stewardship for Agentic InfrastructureBy Om-Shree-0709 on .mcpanthropicLinux Foundation
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/ssv445/lorem-ipsum-mcp'
If you have feedback or need assistance with the MCP directory API, please join our Discord server