Interface IBus

apps/cli/src/application/lib/bus.ts:4–10

import z from "zod";

export interface IBus {
    publish(event: z.infer<typeof RunEvent>): Promise<void>;

    // subscribe accepts a handler to handle events
    // and returns a function to unsubscribe
    subscribe(runId: string, handler: (event: z.infer<typeof RunEvent>) => Promise<void>): Promise<() => void>;
}

export class InMemoryBus implements IBus {
    private subscribers: Map<string, ((event: z.infer<typeof RunEvent>) => Promise<void>)[]> = new Map();