queue.append(packet)
check_outbound()
-def crashy(): assert(False)
-
class ResponseConsumer(twisted.internet.protocol.Protocol):
def __init__(self, req):
self._req = req
- self._ssd = SlipStreamDecoder(crashy)
+ self._ssd = SlipStreamDecoder('req %s' % id(req), queue_inbound)
self._log(DBG.HTTP_CTRL, '__init__')
def _log(self, dflag, msg, **kwargs):