trader/core/price_handler/ccxt_live.py
async def stream_next(self):
        """
        Place the next BarEvent onto the event queue.
        """
        bar_event = None
        if not self.__is_session_time_done(datetime.datetime.now()):
            try:
                for ticker in self.tickers:
                    bar_event = await self.__stream_bar_event(ticker)
                    await self.events_queue.put(bar_event)
                """
                If next cycle exceeds the limit of session time then
                terminate so consumer whould not wait till next timeframe
                """
                next_now_dt = date_utils.add_timeframe_to_date(
                    datetime.datetime.now(), self.timeframe)

                if self.__is_session_time_done(next_now_dt):
                    await self.events_queue.put(None)
                    bar_event = None
            except (ExchangeError, NetworkError) as e:
                raise ExchangeRequestError(e)
        else:
            await self.events_queue.put(None)

        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):
        bar_event = None
        if not self.__is_session_time_done(datetime.datetime.now()):
            try:
                for ticker in self.tickers:
                    bar_event = await self.__stream_bar_event(ticker)
                    await self.events_queue.put(bar_event)
                next_now_dt = date_utils.add_timeframe_to_date(
                    datetime.datetime.now(), self.timeframe)
                if self.__is_session_time_done(next_now_dt):
                    await self.events_queue.put(None)
                    bar_event = None
            except (ExchangeError, NetworkError) as e:
                raise ExchangeRequestError(e)
        else:
            await self.events_queue.put(None)
        return True if bar_event else None
async def stream_next ( self ) : bar_event = None if not self . __is_session_time_done ( datetime . datetime . now ( ) ) : try : for ticker in self . tickers : bar_event = await self . __stream_bar_event ( ticker ) await self . events_queue . put ( bar_event ) """
                If next cycle exceeds the limit of session time then
                terminate so consumer whould not wait till next timeframe
                """ next_now_dt = date_utils . add_timeframe_to_date ( datetime . datetime . now ( ) , self . timeframe ) if self . __is_session_time_done ( next_now_dt ) : await self . events_queue . put ( None ) bar_event = None except ( ExchangeError , NetworkError ) as e : raise ExchangeRequestError ( e ) else : await self . events_queue . put ( None ) 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.
        """ """
                If next cycle exceeds the limit of session time then
                terminate so consumer whould not wait till next timeframe
                """
self