class Deploy::CLI::WebsocketClient::Subscription
Attributes
exchange[R]
routing_key[R]
Public Class Methods
new(exchange, routing_key)
click to toggle source
# File lib/deploy/cli/websocket_client.rb, line 13 def initialize(exchange, routing_key) @exchange = exchange @routing_key = routing_key @events = {} end
Public Instance Methods
dispatch(event, payload)
click to toggle source
# File lib/deploy/cli/websocket_client.rb, line 24 def dispatch(event, payload) return unless @events[event] @events[event].each do |block| block.call(payload) end end
on(event, &block)
click to toggle source
# File lib/deploy/cli/websocket_client.rb, line 19 def on(event, &block) @events[event] ||= [] @events[event] << block end
subscribed!()
click to toggle source
# File lib/deploy/cli/websocket_client.rb, line 36 def subscribed! @subscribed = true end
subscribed?()
click to toggle source
# File lib/deploy/cli/websocket_client.rb, line 32 def subscribed? @subscribed == true end