btfxwss/queue_processor.py
def join(self, timeout=None):
        """Set sentinel for run() method and join thread.

        :param timeout:
        :return:
        """
        self._stopped.set()
        super(QueueProcessor, self).join(timeout=timeout)
def join(self, timeout=None):
        """Set sentinel for run() method and join thread.

        :param timeout:
        :return:
        """
        self._stopped.set()
        super(QueueProcessor, self).join(timeout=timeout)
def join ( self , timeout = None ) : self . _stopped . set ( ) super ( QueueProcessor , self ) . join ( timeout = timeout )
Set sentinel for run() method and join thread.

        :param timeout:
        :return:
Set sentinel for run () method and join thread .