Merge pull request #58 from CharlotteDunoisLabs/sink-array

Resolve with array instead of SplObjectStorage (AdapterInterface::ls(), Node\DirectoryInterface::lsRecursive(), Node\NodeInterface::copy, ObjectStreamSink::promise())

Author: WyriHaximus

README.md

@@ -124,7 +124,7 @@ List contents
 -------------
 
 ```php
-$filesystem->dir(__DIR__)->ls()->then(function (\SplObjectStorage $list) {
+$filesystem->dir(__DIR__)->ls()->then(function (array $list) {
    foreach ($list as $node) {
        echo $node->getPath(), PHP_EOL;
    }

examples/directory_create_recursive.php

@@ -13,7 +13,7 @@
 echo 'Creating directory: ' . $dirName, PHP_EOL;
 $dir->createRecursive('rwxrwx---')->then(function () use ($startDir) {
     return $startDir->lsRecursive();
-})->then(function (\SplObjectStorage $list) {
+})->then(function (array $list) {
     foreach ($list as $node) {
         echo $node->getPath(), PHP_EOL;
     }

examples/directory_ls.php

@@ -6,7 +6,7 @@
 
 $filesystem = \React\Filesystem\Filesystem::create($loop);
 echo 'Using ', get_class($filesystem->getAdapter()), PHP_EOL;
-$filesystem->dir(__DIR__ . DIRECTORY_SEPARATOR . 'tmp')->ls()->then(function (\SplObjectStorage $list) {
+$filesystem->dir(__DIR__ . DIRECTORY_SEPARATOR . 'tmp')->ls()->then(function (array $list) {
     foreach ($list as $node) {
         echo get_class($node), ': ', $node->getPath(), PHP_EOL;
     }

examples/directory_ls_recursive.php

@@ -6,7 +6,7 @@
 
 $filesystem = \React\Filesystem\Filesystem::create($loop);
 echo 'Using ', get_class($filesystem->getAdapter()), PHP_EOL;
-$filesystem->dir(dirname(__DIR__))->lsRecursive()->then(function (\SplObjectStorage $list) {
+$filesystem->dir(dirname(__DIR__))->lsRecursive()->then(function (array $list) {
     foreach ($list as $node) {
         echo $node->getPath(), PHP_EOL;
     }

examples/directory_ls_recursive_regexp_interfaces.php

@@ -6,8 +6,10 @@
 
 $filesystem = \React\Filesystem\Filesystem::create($loop);
 echo 'Using ', get_class($filesystem->getAdapter()), PHP_EOL;
-$filesystem->dir(dirname(__DIR__))->lsRecursive()->then(function (\SplObjectStorage $list) {
-    $interfaces = new RegexIterator($list, '/.*?Interface.php$/');
+$filesystem->dir(dirname(__DIR__))->lsRecursive()->then(function (array $list) {
+    $iterator = new ArrayIterator($list);
+    $interfaces = new RegexIterator($iterator, '/.*?Interface.php$/');
+
     foreach ($interfaces as $node) {
         echo $node->getPath(), PHP_EOL;
     }

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));
     }
 }