code: def handle(self):
          
          logger = StreamHandler.logger
          logger.debug("handling requests with message handler %s " % StreamHandler.message_handler.__class__.__name__)
  
          message_handler = StreamHandler.message_handler
  
          try:
              while True:
                  logger.debug('waiting for more data')
                  if not message_handler.handle(self.request, StreamHandler.BUFFER_SIZE):
                      break
  
              logger.warning("connection closed from %s" % (self.client_address[0]))
              self.request.close()
          except:
              logger.exception("connection closed from %s" % (self.client_address[0]))
          finally:
              self.request.close()
docs: The required handle method.