def enqueue_message(self, message, timeout):
    """Add the given message to this transport's queue.

    This method also handles ACKing any WRTE messages.

    Args:
      message: The AdbMessage to enqueue.
      timeout: The timeout to use for the operation.  Specifically, WRTE
        messages cause an OKAY to be sent; timeout is used for that send.
    """
    # Ack WRTE messages immediately, handle our OPEN ack if it gets enqueued.
    if message.command == 'WRTE':
      self._send_command('OKAY', timeout=timeout)
    elif message.command == 'OKAY':
      self._set_or_check_remote_id(message.arg0)
    self.message_queue.put(message)
def enqueue_message ( self , message , timeout ) : if message . command == 'WRTE' : self . _send_command ( 'OKAY' , timeout = timeout ) elif message . command == 'OKAY' : self . _set_or_check_remote_id ( message . arg0 ) self . message_queue . put ( message )
Add the given message to this transport's queue.

    This method also handles ACKing any WRTE messages.

    Args:
      message: The AdbMessage to enqueue.
      timeout: The timeout to use for the operation.  Specifically, WRTE
        messages cause an OKAY to be sent; timeout is used for that send.