eventbus

package

v1.0.0 Latest Latest Go to latest Published: Jun 1, 2026 License: MIT Imports: 2 Imported by: 0

Details

Package eventbus provides a central message hub for application events and updates.

This section is empty.

This section is empty.

This section is empty.

type EventBus struct {
	// contains filtered or unexported fields
}

EventBus facilitates bi-directional communication between the UI and Workflow. It buffers updates to the UI and actions to the workflow.

func New() *EventBus

New creates and starts a new EventBus.

func (b *EventBus) Close()

Close signals that no more updates or actions will be sent. It blocks until all already-buffered updates have been delivered.

func (b *EventBus) SendAction(act domain.Action)

SendAction queues an action for the workflow. It never blocks.

func (b *EventBus) SendUIUpdate(upd domain.UIUpdate)

SendUIUpdate queues an update for the UI. It never blocks.

func (b *EventBus) UIUpdates() <-chan domain.UIUpdate

UIUpdates returns the channel for receiving UI updates.

func (b *EventBus) WorkflowActions() <-chan domain.Action

WorkflowActions returns the channel for receiving workflow actions.