/**
 * `subscribeAndEmit` — drives a `bus.waitFor` loop and writes one stdout line
 * per emitted event to the caller-supplied stdout target. Pure translator
 * lives in `lineForEvent`.
 *
 * Contract: `contracts/subscribe-and-emit.md`.
 */
import type { EpicEventBus } from '../mcp/event-bus.js';
import type { CockpitStreamEvent } from '../watch/stream-event.js';
export interface SubscribeEmitOptions {
    stdout: {
        write(chunk: string, cb?: () => void): boolean | void;
    };
    onEmit?: (event: CockpitStreamEvent) => void;
}
export type SubscribeUnsubscribe = () => void;
export declare function lineForEvent(event: CockpitStreamEvent): string;
export declare function subscribeAndEmit(bus: EpicEventBus, options: SubscribeEmitOptions): SubscribeUnsubscribe;
//# sourceMappingURL=subscribe.d.ts.map