Let ObjectStreamSink::promise resolve with an array

Author: Charlotte Dunois

src/ObjectStreamSink.php

@@ -13,12 +13,12 @@ class ObjectStreamSink
     public static function promise(ObjectStream $stream)
     {
         $deferred = new Deferred();
-        $list = new \SplObjectStorage();
+        $list = array();
 
-        $stream->on('data', function ($object) use ($list) {
-            $list->attach($object);
+        $stream->on('data', function ($object) use (&$list) {
+            $list[] = $object;
         });
-        $stream->on('end', function () use ($deferred, $list) {
+        $stream->on('end', function () use ($deferred, &$list) {
             $deferred->resolve($list);
         });
 

tests/Adapters/DirectoryTest.php

@@ -21,9 +21,8 @@ public function testLs(LoopInterface $loop, FilesystemInterface $filesystem)
         $path = $this->tmpDir . 'path';
         touch($path);
         $listing = $this->await($filesystem->dir($this->tmpDir)->ls(), $loop);
-        $listing->rewind();
-        $this->assertSame(1, $listing->count());
-        $this->assertSame($path, $listing->current()->getPath());
+        $this->assertSame(1, count($listing));
+        $this->assertSame($path, reset($listing)->getPath());
     }
 
     /**

tests/ChildProcess/AdapterTest.php

@@ -319,9 +319,8 @@ public function testLs()
         ]);
 
         $nodes = $this->await($promise, $loop);
-        $nodes->rewind();
 
-        $this->assertEquals(new File('foo.bar/bar.foo', $fs), $nodes->current());
+        $this->assertEquals(new File('foo.bar/bar.foo', $fs), reset($nodes));
     }
 
     public function testLsStream()

tests/ObjectStreamSinkTest.php

@@ -15,12 +15,13 @@ public function testSink()
         $this->assertInstanceOf('React\Promise\PromiseInterface', $sink);
         $stream->emit('data', [$node]);
         $stream->close();
+
         $nodes = null;
-        $sink->then(function (\SplObjectStorage $list) use (&$nodes) {
+        $sink->then(function ($list) use (&$nodes) {
             $nodes = $list;
         });
-        $nodes->rewind();
-        $this->assertSame(1, $nodes->count());
-        $this->assertSame($node, $nodes->current());
+
+        $this->assertSame(1, count($nodes));
+        $this->assertSame($node, reset($nodes));
     }
 }