class

Autobot::Bus::MessageBus

Inherits Reference < Object

Event-driven message bus using Crystal channels for async communication

Constants

Log = ::Log.for("bus")

Constructors

new(capacity : Int32 = 100)
Source

Instance methods

consume_inbound

Consume inbound messages (agent reads these)

Source
consume_outbound

Consume outbound messages (channels read these)

Source
publish_inbound(message : InboundMessage) : Nil

Publish an inbound message (from channels to agent)

Source
publish_outbound(message : OutboundMessage) : Nil

Publish an outbound message (from agent to channels)

Source
stop

Stop the bus gracefully

Source
stopped?

Check if bus is stopped

Source