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