Module: BitShares::WSocket

Defined in:
lib/bitshares/wsocket.rb

Class Method Summary collapse

Class Method Details

.get_notice ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/bitshares/wsocket.rb', line 56

def get_notice
  if @msgs.key?('notice') && !@msgs['notice'].nil?
    msg = @msgs['notice']
    lock.synchronize do
      @msgs['notice'] = nil
    end
    msg
  else
    nil
  end
end

.lock ⇒ Object 



54
 
# File 'lib/bitshares/wsocket.rb', line 54

def lock() @lock ||= Mutex.new end

.send(hash) ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/bitshares/wsocket.rb', line 31

def send hash
  id = hash[:id]
  count = 0
  while @msgs[id] != nil do
    sleep 0.1
    count += 1
    raise "TimeoutError..." if count > 100
  end
  @thread[:ws].send hash.to_json if @status == :connected
  count = 0
  while @msgs[id].nil? and @status == :connected do
    sleep 0.1
    count += 1
    raise "TimeoutError..." if count > 100
  end

  result = @msgs[id]
  lock.synchronize do
    @msgs[id] = nil
  end
  result
end

.start ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/bitshares/wsocket.rb', line 8

def start
  @msgs = {}
  @thread ||= Thread.new { run }
  Thread.new do
    while @status != :disconnected do
      @thread[:ws].ping 'Hi' if @status == :connected
      sleep 50
    end
  end
  count = 0
  while @status != :connected and @status != :disconnected do
    sleep 0.1
    count += 1
    raise "TimeoutError..." if count > 100
  end
end

.stop ⇒ Object 



27
28
29
 
# File 'lib/bitshares/wsocket.rb', line 27

def stop
  EventMachine.stop
end

.thread ⇒ Object 



25
 
# File 'lib/bitshares/wsocket.rb', line 25

def thread() @thread end