class

CRE::Engine::EventBus

Inherits Reference < Object

Constants

Log = ::Log.for("cre.event_bus")

Constructors

new(inbox_capacity : Int32 = 1024, block_send_timeout : Time::Span = 5.seconds)
Source

Instance methods

publish(event : Events::Event) : Nil
Source
stop
Source
subscribe(buffer : Int32 = 64, overflow : Overflow = Overflow::Block) : Channel(Events::Event)
Source

Nested types