class Enterprice::IO::MultiCandleStream

Public Class Methods

new(period, block) click to toggle source
# File lib/enterprice/io/multi_candle_stream.rb, line 6
def initialize(period, block)
  @streams= {}
  @period= period
  @block= block
end
start(period, &block) click to toggle source
# File lib/enterprice/io/multi_candle_stream.rb, line 19
def self.start(period, &block)
  MultiCandleStream.new(period, block) 
end

Public Instance Methods

<<(row) click to toggle source
# File lib/enterprice/io/multi_candle_stream.rb, line 12
def << (row)
  if @streams[row[0]].nil?
    @streams[row[0]]= NamedCandleStream.new(@period, row[0], @block)
  end
  @streams[row[0]]<< row[1..-1]
end