/** * OrchestrationReactor - Composite orchestration reactor service interface. * * Coordinates startup of orchestration runtime reactors that translate domain * events into downstream side effects. * * @module OrchestrationReactor */import * as Context from "effect/Context";import type * as Effect from "effect/Effect";import type * as Scope from "effect/Scope";/** * OrchestrationReactorShape - Service API for orchestration reactor lifecycle. */export interface OrchestrationReactorShape { /** * Start orchestration-side reactors for provider/runtime/checkpoint flows. * * The returned effect must be run in a scope so all worker fibers can be * finalized on shutdown. */ readonly start: () => Effect.Effect<void, never, Scope.Scope>;}/** * OrchestrationReactor - Service tag for orchestration reactor coordination. */export class OrchestrationReactor extends Context.Service< OrchestrationReactor, OrchestrationReactorShape>()("t3/orchestration/Services/OrchestrationReactor") {}
/**
* OrchestrationReactor - Composite orchestration reactor service interface.
*
* Coordinates startup of orchestration runtime reactors that translate domain
* events into downstream side effects.
*
* @module OrchestrationReactor
*/
import * as Context from "effect/Context";
import type * as Effect from "effect/Effect";
import type * as Scope from "effect/Scope";
/**
* OrchestrationReactorShape - Service API for orchestration reactor lifecycle.
*/
export interface OrchestrationReactorShape {
/**
* Start orchestration-side reactors for provider/runtime/checkpoint flows.
*
* The returned effect must be run in a scope so all worker fibers can be
* finalized on shutdown.
*/
readonly start: () => Effect.Effect<void, never, Scope.Scope>;
}
/**
* OrchestrationReactor - Service tag for orchestration reactor coordination.
*/
export class OrchestrationReactor extends Context.Service<
OrchestrationReactor,
OrchestrationReactorShape
>()("t3/orchestration/Services/OrchestrationReactor") {}