Class: Mcoin::Subscriber

Inherits:
Object
  • Object
show all
Defined in:
lib/mcoin/subscriber.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(pairs = nil, markets = Market.available) ⇒ Subscriber

Returns a new instance of Subscriber.



7
8
9
10
 
# File 'lib/mcoin/subscriber.rb', line 7

def initialize(pairs = nil, markets = Market.available)
  @pairs = pairs_from(pairs)
  @markets = markets_from(markets)
end

Instance Attribute Details

#markets ⇒ Object (readonly)

Returns the value of attribute markets.



5
6
7
 
# File 'lib/mcoin/subscriber.rb', line 5

def markets
  @markets
end

#pairs ⇒ Object (readonly)

Returns the value of attribute pairs.



5
6
7
 
# File 'lib/mcoin/subscriber.rb', line 5

def pairs
  @pairs
end

Instance Method Details

#start(interval = 1, &block) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/mcoin/subscriber.rb', line 12

def start(interval = 1, &block)
  loop do
    Parallel.async(@markets, :fetch) do |result|
      result.to_ticker.each do |ticker|
        yield ticker
      end
    end

    sleep interval
  end
end