Added test case for Windows EOL that is cut off just before the last byte, making the first byte of the next message be a new line.

Author: boenrobot

tests/EventSourceTest.php

@@ -656,6 +656,35 @@ public function testSplitMessagesWithWindowsEndOfLineSequence()
         }
     }
 
+    public function testSplitMessagesWithBufferedWindowsEndOfLineSequence()
+    {
+        $deferred = new Deferred();
+        $browser = $this->getMockBuilder('React\Http\Browser')->disableOriginalConstructor()->getMock();
+        $browser->expects($this->once())->method('withRejectErrorResponse')->willReturnSelf();
+        $browser->expects($this->once())->method('requestStreaming')->willReturn($deferred->promise());
+
+        $es = new EventSource('http://example.com', $browser);
+
+        $stream = new ThroughStream();
+        $response = new Response(200, array('Content-Type' => 'text/event-stream'), new ReadableBodyStream($stream));
+        $deferred->resolve($response);
+
+        $messages = [];
+        $es->on('message', function ($m) use (&$messages) {
+            $messages[] = $m;
+        });
+
+        $stream->write("data:hello\r\n\r");
+        $stream->write("\ndata:hi\r\n\r\n");
+
+        $expected = ['hello', 'hi'];
+        $this->assertCount(count($expected), $messages);
+        foreach ($messages as $i => $message) {
+            $this->assertInstanceOf('Clue\React\EventSource\MessageEvent', $message);
+            $this->assertEquals($expected[$i], $message->data);
+        }
+    }
+
     public function testSplitMessagesWithMixedEndOfLine()
     {
         $deferred = new Deferred();