Add tests to exhibit SSL/TLS buffering issues

Test receiving larger buffers without ending the stream

Author: clue

tests/SecureIntegrationTest.php

@@ -117,6 +117,29 @@ public function testSendDataWithEndToServerReceivesAllData()
         $this->assertEquals($data, $received);
     }
 
+    public function testSendDataWithoutEndingToServerReceivesAllData()
+    {
+        $received = '';
+        $this->server->on('connection', function (Stream $peer) use (&$received) {
+            $peer->on('data', function ($chunk) use (&$received) {
+                $received .= $chunk;
+            });
+        });
+
+        $client = Block\await($this->connector->create('127.0.0.1', $this->portSecure), $this->loop);
+        /* @var $client Stream */
+
+        $data = str_repeat('d', 200000);
+        $client->write($data);
+
+        // buffer incoming data for 0.1s (should be plenty of time)
+        Block\sleep(0.1, $this->loop);
+
+        $client->close();
+
+        $this->assertEquals($data, $received);
+    }
+
     public function testConnectToServerWhichSendsSmallDataReceivesOneChunk()
     {
         $this->server->on('connection', function (Stream $peer) {
@@ -149,6 +172,28 @@ public function testConnectToServerWhichSendsDataWithEndReceivesAllData()
         $this->assertEquals($data, $received);
     }
 
+    public function testConnectToServerWhichSendsDataWithoutEndingReceivesAllData()
+    {
+        $data = str_repeat('c', 100000);
+        $this->server->on('connection', function (Stream $peer) use ($data) {
+            $peer->write($data);
+        });
+
+        $client = Block\await($this->connector->create('127.0.0.1', $this->portSecure), $this->loop);
+        /* @var $client Stream */
+
+        // buffer incoming data for 0.1s (should be plenty of time)
+        $received = '';
+        $client->on('data', function ($chunk) use (&$received) {
+            $received .= $chunk;
+        });
+        Block\sleep(0.1, $this->loop);
+
+        $client->close();
+
+        $this->assertEquals($data, $received);
+    }
+
     private function createPromiseForEvent(EventEmitterInterface $emitter, $event, $fn)
     {
         return new Promise(function ($resolve) use ($emitter, $event, $fn) {