Spectrum::EventQueue
Inherits Reference < Object
Constructors
get(name : Symbol) : self
Sourcenew(event_handlers : EventHandlers, number_of_workers : Int32, queue_size : Int32, queue_timeout : Int32)
SourceClass methods
start(name : Symbol, number_of_workers : Int32 = 1, queue_size : Int32 = 1000, queue_timeout : Int32 = 30) : self | Nil
Sourcestop(name : Symbol) : self | Nil
SourceInstance methods
running?
Sourcesend(event : Event) : self
Sourcesomething?
Sourcestart
Sourcestop
Sourcestopped?
Sourceworkers_not_dead?
Sourceworkers_running?
Source