fix, wrong var name

alpacahq · Mar 4, 2021 · 2224654 · 2224654
1 parent b83670c
commit 2224654
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/alpaca_backtrader_api/alpacastore.py b/alpaca_backtrader_api/alpacastore.py
@@ -135,11 +135,11 @@ def __init__(
 
     def run(self):
         if self.method == StreamingMethod.AccountUpdate:
-            stream.subscribe_trade_updates(self.on_trade)
+            self.conn.subscribe_trade_updates(self.on_trade)
         elif self.method == StreamingMethod.MinuteAgg:
-            stream.subscribe_bars(self.on_agg_min, self.instrument)
+            self.conn.subscribe_bars(self.on_agg_min, self.instrument)
         elif self.method == StreamingMethod.Quote:
-            stream.subscribe_quotes(self.on_quotes, self.instrument)
+            self.conn.subscribe_quotes(self.on_quotes, self.instrument)
 
         # this code runs in a new thread. we need to set the loop for it
         loop = asyncio.new_event_loop()