import type { ArvoEvent } from 'arvo-core'; export type EventBusListener = (event: ArvoEvent, publish: (event: ArvoEvent) => Promise) => Promise; export interface EventBusOptions { maxQueueSize: number; errorHandler: (error: Error, event: ArvoEvent) => void; }