trader/core/price_handler/ccxt_historic.py
async def stream_next(self):
        """
        Place the next BarEvent onto the event queue.
        """
        try:
            candle = next(self.candles_stream)
            bar_event = candles_utils.create_bar_event(candle, self.timeframe)
            print('bar_event: ', type(bar_event), bar_event)
            self.tickers_data_index[bar_event.ticker] += 1
        except StopIteration:
            bar_event = None
        finally:
            await self.events_queue.put(bar_event)
            return True if bar_event else None

        Place the next BarEvent onto the event queue.
        
Place the next BarEvent onto the event queue.
Place the next BarEvent onto the event queue .
async def stream_next(self):
        try:
            candle = next(self.candles_stream)
            bar_event = candles_utils.create_bar_event(candle, self.timeframe)
            print('bar_event: ', type(bar_event), bar_event)
            self.tickers_data_index[bar_event.ticker] += 1
        except StopIteration:
            bar_event = None
        finally:
            await self.events_queue.put(bar_event)
            return True if bar_event else None
async def stream_next ( self ) : try : candle = next ( self . candles_stream ) bar_event = candles_utils . create_bar_event ( candle , self . timeframe ) print ( 'bar_event: ' , type ( bar_event ) , bar_event ) self . tickers_data_index [ bar_event . ticker ] += 1 except StopIteration : bar_event = None finally : await self . events_queue . put ( bar_event ) return True if bar_event else None
Place the next BarEvent onto the event queue.
Place the next BarEvent onto the event queue .
"""
        Place the next BarEvent onto the event queue.
        """
self