Class: OBS::WebSocket::EventDispatcher

Inherits:

Object

• Object
• OBS::WebSocket::EventDispatcher

Defined in:

lib/obs/websocket.rb

Instance Method Summary

• #dispatch(update_type, payload) ⇒ Object
• #initialize ⇒ EventDispatcher constructor

  A new instance of EventDispatcher.

• #register(executor, type, listener) ⇒ Object

Constructor Details

#initialize ⇒ EventDispatcher

Returns a new instance of EventDispatcher.

# File 'lib/obs/websocket.rb', line 147

def initialize
  @listeners = Hash.new {|h, k| h[k] = []}
end

Instance Method Details

#dispatch(update_type, payload) ⇒ Object

# File 'lib/obs/websocket.rb', line 155

def dispatch(update_type, payload)
  event = Protocol::Event.create(update_type, payload).freeze
  @listeners[update_type].each do |(executor, listener)|
    Concurrent::Promises.future_on(executor, event, &listener).run
  end
end

#register(executor, type, listener) ⇒ Object

# File 'lib/obs/websocket.rb', line 151

def register(executor, type, listener)
  @listeners[type].push([executor, listener])
end