parameters: (self, mux_handler)
docstring: Constructs an instance.
  
          Args:
              mux_handler: _MuxHandler instance.
docstring_summary: Constructs an instance.
docstring_tokens: Constructs an instance .
function: def __init__(self, mux_handler):
          """Constructs an instance.
  
          Args:
              mux_handler: _MuxHandler instance.
          """
  
          threading.Thread.__init__(self)
          self._logger = util.get_class_logger(self)
          self._mux_handler = mux_handler
          self.setDaemon(True)
  
          # When set, make this thread stop accepting new data, flush pending
          # data and exit.
          self._stop_requested = False
          # The close code of the physical connection.
          self._close_code = common.STATUS_NORMAL_CLOSURE
          # Deque for passing write data. It's protected by _deque_condition
          # until _stop_requested is set.
          self._deque = collections.deque()
          # - Protects _deque, _stop_requested and _close_code
          # - Signals threads waiting for them to be available
          self._deque_condition = threading.Condition()
function_tokens: def __init__ ( self , mux_handler ) : threading . Thread . __init__ ( self ) self . _logger = util . get_class_logger ( self ) self . _mux_handler = mux_handler self . setDaemon ( True ) # When set, make this thread stop accepting new data, flush pending # data and exit. self . _stop_requested = False # The close code of the physical connection. self . _close_code = common . STATUS_NORMAL_CLOSURE # Deque for passing write data. It's protected by _deque_condition # until _stop_requested is set. self . _deque = collections . deque ( ) # - Protects _deque, _stop_requested and _close_code # - Signals threads waiting for them to be available self . _deque_condition = threading . Condition ( )