import { StreamContract } from "../contracts/stream/stream.contract.mjs";
import { SupervisorStreamEvent } from "../contracts/supervisor/supervisor-stream-event.type.mjs";

//#region ../ai/src/supervisor/supervisor-stream.d.ts
/**
 * Internal async-queue controller driving `supervisor.stream()`.
 * Mirrors `StreamController` from `agent-stream.ts` — same
 * producer/consumer pipe, same semantics, parameterized by the
 * supervisor event union and terminal result type.
 */
type SupervisorStreamController<TResult> = {
  push(event: SupervisorStreamEvent): void;
  end(result: TResult): void;
  fail(error: Error): void;
};
/**
 * Factory mirroring `createAgentStream`. Returns a paired
 * `{ controller, stream }` — the `SupervisorExecution` pushes events
 * into the controller while the caller iterates (or awaits `.result`)
 * on the stream side. See `agent-stream.ts` for the full role
 * description.
 */
declare function createSupervisorStream<TResult>(): {
  controller: SupervisorStreamController<TResult>;
  stream: StreamContract<TResult, SupervisorStreamEvent>;
};
//#endregion
export { SupervisorStreamController, createSupervisorStream };
//# sourceMappingURL=supervisor-stream.d.mts.map