- log_debug(dflag, 'RC ' + msg, idof=self._req, **kwargs)
+ log_debug(dflag, '%s: %s' % (self._desc, msg), idof=self._req, **kwargs)
+
+ def connectionMade(self):
+ self._log(DBG.HTTP_CTRL, 'connectionMade')
+
+class ResponseConsumer(GeneralResponseConsumer):
+ def __init__(self, req):
+ super().__init__(req, 'RC')
+ ssddesc = '[%s] %s' % (id(req), self._desc)
+ self._ssd = SlipStreamDecoder(ssddesc, queue_inbound)
+ self._log(DBG.HTTP_CTRL, '__init__')