code: def _thread_body(self, request, callback):
          
          self.protocol.send_message(request)
          while not self.protocol.stopped.isSet():
              response = self.queue.get(block=True)
              callback(response)
docs: Private function. Send a request, wait for response and call the callback function.
  
          :param request: the request to send
          :param callback: the callback function