Unified · Split
| @@ -41,7 +41,7 @@ import * as Stream from "effect/Stream"; · 40 unmodified lines | |||
| 41 | 41 | ||
| 42 | import { CheckpointServiceV2 } from "./CheckpointService.ts"; | 42 | import { CheckpointServiceV2 } from "./CheckpointService.ts"; |
| 43 | import { CommandPolicyV2 } from "./CommandPolicy.ts"; | 43 | import { CommandPolicyV2 } from "./CommandPolicy.ts"; |
| 44 | import { CommandReceiptStoreV2, type CommandReceiptStoreV2Shape } from "./CommandReceiptStore.ts"; | 44 | import { CommandReceiptStoreV2 } from "./CommandReceiptStore.ts"; |
| 45 | import { ContextHandoffServiceV2 } from "./ContextHandoffService.ts"; | 45 | import { ContextHandoffServiceV2 } from "./ContextHandoffService.ts"; |
| 46 | import { EventSinkV2 } from "./EventSink.ts"; | 46 | import { EventSinkV2 } from "./EventSink.ts"; |
| 47 | import type { OrchestrationEffectRequestV2, PendingOrchestrationEffectV2 } from "./EffectOutbox.ts"; | 47 | import type { OrchestrationEffectRequestV2, PendingOrchestrationEffectV2 } from "./EffectOutbox.ts"; |
| @@ -183,7 +183,7 @@ export interface OrchestratorV2Shape { · 135 unmodified lines | |||
| 183 | readonly dispatch: ( | 183 | readonly dispatch: ( |
| 184 | command: OrchestrationV2Command, | 184 | command: OrchestrationV2Command, |
| 185 | ) => Effect.Effect<OrchestratorV2DispatchResult, OrchestratorV2Error>; | 185 | ) => Effect.Effect<OrchestratorV2DispatchResult, OrchestratorV2Error>; |
| 186 | readonly getCommandReceipt: CommandReceiptStoreV2Shape["getByCommandId"]; | 186 | readonly getCommandReceipt: CommandReceiptStoreV2["Service"]["getByCommandId"]; |
| 187 | readonly getThreadProjection: ( | 187 | readonly getThreadProjection: ( |
| 188 | threadId: ThreadId, | 188 | threadId: ThreadId, |
| 189 | ) => Effect.Effect<OrchestrationV2ThreadProjection, OrchestratorV2Error>; | 189 | ) => Effect.Effect<OrchestrationV2ThreadProjection, OrchestratorV2Error>; |