Class: NotificationBus
Defined in: packages/orchestration/src/crew/notification-bus.ts:12
Accumulates orchestrator events as structured notifications for the coordinator agent.
The coordinator drains this bus before each turn to get context about what workers have done since the last interaction.
Constructors
Constructor
new NotificationBus(
events):NotificationBus
Defined in: packages/orchestration/src/crew/notification-bus.ts:18
Parameters
events
EventBus<OrchestrationEventMap>
Returns
NotificationBus
Methods
dispose()
dispose():
void
Defined in: packages/orchestration/src/crew/notification-bus.ts:120
Unsubscribe from all orchestrator events
Returns
void
drain()
drain():
CrewNotification[]
Defined in: packages/orchestration/src/crew/notification-bus.ts:82
Returns and clears all pending notifications
Returns
formatForCoordinator()
formatForCoordinator():
string
Defined in: packages/orchestration/src/crew/notification-bus.ts:97
Render pending notifications as a text block for the coordinator. Returns empty string if no pending notifications.
Returns
string
hasPending()
hasPending():
boolean
Defined in: packages/orchestration/src/crew/notification-bus.ts:89
Check if there are pending notifications
Returns
boolean