Class: CrossSpec::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/cross_spec/client.rb

Instance Method Summary collapse

Constructor Details

#initialize(driver, handlers = {}) ⇒ Client

Returns a new instance of Client.



3
4
5
6
 
# File 'lib/cross_spec/client.rb', line 3

def initialize(driver, handlers = {})
  @driver = driver
  @handlers = Hash(handlers)
end

Instance Method Details

#broadcast(str) ⇒ Object 



8
9
10
 
# File 'lib/cross_spec/client.rb', line 8

def broadcast(str)
  @driver.broadcast(str)
end

#listen!(&block) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/cross_spec/client.rb', line 12

def listen!(&block)
  @driver.each_message do |message|
    json = JSON.parse(message)
    message = if json.key?("service")
      ServiceMessage.from_json(json)
    elsif json.key?("task")
      TaskMessage.from_json(json)
    end

    next unless message

    result = if block_given?
      yield message
    elsif message.is_a?(TaskMessage) && @handlers[message.task]
      @handlers[message.task].call(message)
    elsif message.is_a?(ServiceMessage) && @handlers[message.service]
      @handlers[message.service].call(message)
    end

    return unless result.nil?
  end
end