spacepaste

  1.  
  2. @implementer(twisted.internet.interfaces.IHandshakeListener)
  3. class MyProxy(twisted.internet.protocol.Protocol):
  4. def dataReceived(self, data):
  5. raise RuntimeError('boom')
  6. def handshakeCompleted(self):
  7. self.transport.pauseProducing()
  8.