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