'abortConnection() is triggered by a write buffer being full.
However, this buffer is filled after some bytes have been exchanged,
allowing a TLS handshake if we\'re testing TLS. The connection will
then be lost.'

def test_fullWriteBufferAfterByteExchange(self):

    return self.runAbortTest(StreamingProducerClientLater, EventualNoReadServer)
