📦 SQA::Stream

Source Information

Defined in: lib/sqa/stream.rb:39

Inherits from: Object

🔨 Instance Methods

#ticker()

Returns the value of attribute ticker.

Source Location

lib/sqa/stream.rb:40

---

#window_size()

Returns the value of attribute window_size.

Source Location

lib/sqa/stream.rb:40

---

#strategies()

Returns the value of attribute strategies.

Source Location

lib/sqa/stream.rb:40

---

#data_buffer()

Returns the value of attribute data_buffer.

Source Location

lib/sqa/stream.rb:40

---

#indicator_cache()

Returns the value of attribute indicator_cache.

Source Location

lib/sqa/stream.rb:40

---

#initialize(ticker:, window_size: = 100, strategies: = [])

Returns

Type: Stream

a new instance of Stream

Source Location

lib/sqa/stream.rb:42

---

#add_strategy(strategy)

Add a strategy to the stream processor

Source Location

lib/sqa/stream.rb:65

---

#on_signal(&block)

Register callback for trading signals

Example: stream.on_signal do |signal, data| puts "#{signal.upcase} at $#{data[:price]}" end

Source Location

lib/sqa/stream.rb:78

---

#on_update(&block)

Register callback for price updates

Example: stream.on_update do |data| puts "Price updated: $#{data[:price]}" end

Source Location

lib/sqa/stream.rb:89

---

#update(price:, volume: = nil, high: = nil, low: = nil, timestamp: = Time.now)

Update stream with new market data

Required fields: price Optional fields: volume, high, low, timestamp

Source Location

lib/sqa/stream.rb:98

---

#current_price()

Get current price

Source Location

lib/sqa/stream.rb:136

---

#recent_prices(count = nil)

Get recent prices

Source Location

lib/sqa/stream.rb:141

---

#recent_volumes(count = nil)

Get recent volumes

Source Location

lib/sqa/stream.rb:148

---

#indicator(name, **options)

Calculate or retrieve cached indicator

Example: rsi = stream.indicator(:rsi, period: 14) sma = stream.indicator(:sma, period: 20)

Source Location

lib/sqa/stream.rb:159

---

#current_signal()

Get current trading signal from last strategy execution

Source Location

lib/sqa/stream.rb:177

---

#stats()

Get statistics about the stream

Source Location

lib/sqa/stream.rb:182

---

#reset()

Reset the stream (clear all data)

Source Location

lib/sqa/stream.rb:199

---

📝 Attributes

👁️ ticker read-only

Returns the value of attribute ticker.

👁️ window_size read-only

Returns the value of attribute window_size.

👁️ strategies read-only

Returns the value of attribute strategies.

👁️ data_buffer read-only

Returns the value of attribute data_buffer.

👁️ indicator_cache read-only

Returns the value of attribute indicator_cache.