Remove traces of call invokers

Author: WyriHaximus

src/AdapterInterface.php

@@ -33,14 +33,6 @@ public function getLoop();
      */
     public function setFilesystem(FilesystemInterface $filesystem);
 
-    /**
-     * Set the call invoker for this adapter.
-     *
-     * @param CallInvokerInterface $invoker
-     * @return void
-     */
-    public function setInvoker(CallInvokerInterface $invoker);
-
     /**
      * Call the underlying filesystem.
      *

src/CallInvokerInterface.php

@@ -64,11 +64,6 @@ class Adapter implements AdapterInterface
      */
     protected $permissionFlagResolver;
 
-    /**
-     * @var CallInvokerInterface
-     */
-    protected $invoker;
-
     /**
      * @var array
      */
@@ -85,7 +80,6 @@ public function __construct(LoopInterface $loop, array $options = [])
     {
         $this->loop = $loop;
 
-        $this->invoker = \React\Filesystem\getInvoker($this, $options, 'invoker', 'React\Filesystem\InstantInvoker');
         $this->openFileLimiter = new OpenFileLimiter(\React\Filesystem\getOpenFileLimit($options));
         $this->permissionFlagResolver = new PermissionFlagResolver();
 
@@ -145,15 +139,6 @@ public function setFilesystem(FilesystemInterface $filesystem)
         ];
     }
 
-    /**
-     * @param CallInvokerInterface $invoker
-     * @return void
-     */
-    public function setInvoker(CallInvokerInterface $invoker)
-    {
-        $this->invoker = $invoker;
-    }
-
     /**
      * @param string $function
      * @param array $args
@@ -176,7 +161,7 @@ public function callFilesystem($function, $args, $errorResultCode = -1)
      */
     public function chmod($path, $mode)
     {
-        return $this->invoker->invokeCall('chmod', [
+        return $this->callFilesystem('chmod', [
             'path' => $path,
             'mode' => decoct($mode),
         ]);
@@ -189,7 +174,7 @@ public function chmod($path, $mode)
      */
     public function mkdir($path, $mode = self::CREATION_MODE)
     {
-        return $this->invoker->invokeCall('mkdir', [
+        return $this->callFilesystem('mkdir', [
             'path' => $path,
             'mode' => decoct($this->permissionFlagResolver->resolve($mode)),
         ]);
@@ -271,7 +256,7 @@ public function close($fd)
      */
     public function rmdir($path)
     {
-        return $this->invoker->invokeCall('rmdir', [
+        return $this->callFilesystem('rmdir', [
             'path' => $path,
         ]);
     }
@@ -282,7 +267,7 @@ public function rmdir($path)
      */
     public function unlink($path)
     {
-        return $this->invoker->invokeCall('unlink', [
+        return $this->callFilesystem('unlink', [
             'path' => $path,
         ]);
     }
@@ -295,7 +280,7 @@ public function unlink($path)
      */
     public function chown($path, $uid, $gid)
     {
-        return $this->invoker->invokeCall('chown', [
+        return $this->callFilesystem('chown', [
             'path' => $path,
             'uid' => $uid,
             'gid' => $gid,
@@ -308,7 +293,7 @@ public function chown($path, $uid, $gid)
      */
     public function stat($filename)
     {
-        return $this->invoker->invokeCall('stat', [
+        return $this->callFilesystem('stat', [
             'path' => $filename,
         ])->then(function ($stat) {
             $stat['atime'] = new DateTime('@' . $stat['atime']);
@@ -335,7 +320,7 @@ public function lsStream($path)
     {
         $stream = new ObjectStream();
 
-        $this->invoker->invokeCall('readdir', [
+        $this->callFilesystem('readdir', [
             'path' => $path,
             'flags' => $this->options['lsFlags'],
         ])->then(function ($result) use ($path, $stream) {
@@ -372,7 +357,7 @@ protected function processLsContents($basePath, $result, ObjectStream $stream)
      */
     public function touch($path, $mode = self::CREATION_MODE)
     {
-        return $this->invoker->invokeCall('touch', [
+        return $this->callFilesystem('touch', [
             'path' => $path,
             'mode' => decoct($this->permissionFlagResolver->resolve($mode)),
         ]);
@@ -385,7 +370,7 @@ public function touch($path, $mode = self::CREATION_MODE)
      */
     public function rename($fromPath, $toPath)
     {
-        return $this->invoker->invokeCall('rename', [
+        return $this->callFilesystem('rename', [
             'from' => $fromPath,
             'to' => $toPath,
         ]);
@@ -397,7 +382,7 @@ public function rename($fromPath, $toPath)
      */
     public function readlink($path)
     {
-        return $this->invoker->invokeCall('readlink', [
+        return $this->callFilesystem('readlink', [
             'path' => $path,
         ])->then(function ($result) {
             return \React\Promise\resolve($result['path']);
@@ -411,7 +396,7 @@ public function readlink($path)
      */
     public function symlink($fromPath, $toPath)
     {
-        return $this->invoker->invokeCall('symlink', [
+        return $this->callFilesystem('symlink', [
             'from' => $fromPath,
             'to' => $toPath,
         ])->then(function ($result) {

src/ChildProcess/Adapter.php

@@ -44,16 +44,6 @@ class Adapter implements AdapterInterface
      */
     protected $permissionFlagResolver;
 
-    /**
-     * @var CallInvokerInterface
-     */
-    protected $invoker;
-
-    /**
-     * @var CallInvokerInterface
-     */
-    protected $readDirInvoker;
-
     /**
      * @var FilesystemInterface
      */
@@ -96,8 +86,6 @@ public function __construct(LoopInterface $loop, array $options = [])
      */
     protected function applyConfiguration(array $options)
     {
-        $this->invoker = \React\Filesystem\getInvoker($this, $options, 'invoker', 'React\Filesystem\InstantInvoker');
-        $this->readDirInvoker = \React\Filesystem\getInvoker($this, $options, 'read_dir_invoker', 'React\Filesystem\InstantInvoker');
         $this->openFileLimiter = new OpenFileLimiter(\React\Filesystem\getOpenFileLimit($options));
         $this->options = array_merge_recursive($this->options, $options);
     }

src/Eio/Adapter.php

@@ -137,12 +137,4 @@ public function getContents($filename)
             return $file->getContents();
         });
     }
-
-    /**
-     * @param CallInvokerInterface $invoker
-     */
-    public function setInvoker(CallInvokerInterface $invoker)
-    {
-        $this->adapter->setInvoker($invoker);
-    }
 }

src/Filesystem.php

@@ -56,9 +56,4 @@ public function link($path, Node\NodeInterface $destination);
      * @return \React\Promise\PromiseInterface
      */
     public function getContents($filename);
-
-    /**
-     * @param CallInvokerInterface $invoker
-     */
-    public function setInvoker(CallInvokerInterface $invoker);
 }