class

Spectrum::EventQueue

Inherits Reference < Object

Constructors

get(name : Symbol) : self
Source
new(event_handlers : EventHandlers, number_of_workers : Int32, queue_size : Int32, queue_timeout : Int32)
Source

Class methods

start(name : Symbol, number_of_workers : Int32 = 1, queue_size : Int32 = 1000, queue_timeout : Int32 = 30) : self | Nil
Source
stop(name : Symbol) : self | Nil
Source

Instance methods

running?
Source
send(event : Event) : self
Source
something?
Source
start
Source
stop
Source
stopped?
Source
workers_not_dead?
Source
workers_running?
Source

Nested types