@implementer(twisted.internet.interfaces.IHandshakeListener)
class MyProxy(twisted.internet.protocol.Protocol):

    def dataReceived(self, data):
        raise RuntimeError('boom')

    def handshakeCompleted(self):
        self.transport.pauseProducing()