import type { DurableStream } from "@executablemd/durable-streams";
import { type Operation } from "effection";
import type { WorkflowRunDatabase, WorkflowRunTransaction } from "../storage/api.js";
import type { WorkflowRunConnections, WorkflowRunTransactionToken } from "./connections.js";
export declare function useJournalRouting(connections: WorkflowRunConnections): Operation<void>;
export declare function routeWorkflowRunJournal(database: WorkflowRunDatabase, ordinary: DurableStream): DurableStream;
export declare function withEnlistedJournalRoute<T>(database: WorkflowRunDatabase, transaction: WorkflowRunTransaction, token: WorkflowRunTransactionToken, publication: Operation<T>): Operation<T>;