'abortConnection() triggered by the write buffer being full.
In particular, the server side stops reading. This is supposed
to simulate a realistic timeout scenario where the client
notices the server is no longer accepting data.
The protocol should be disconnected, but connectionLost should not be
called re-entrantly.'

def test_fullWriteBuffer(self):

    self.runAbortTest(StreamingProducerClient, NoReadServer)
