Changed return type of AsyncConnector::fetch() from Closure to mixed.

Author: Bilge

src/Connector/AsyncConnector.php

@@ -14,7 +14,7 @@ interface AsyncConnector
      * @param string $source Source.
      * @param ConnectionContext $context Runtime connection settings and methods.
      *
-     * @return \Closure Closure that returns a Promise or raw data.
+     * @return mixed Async generator function or any return value compatible with Amp\call.
      */
-    public function fetchAsync(string $source, ConnectionContext $context): \Closure;
+    public function fetchAsync(string $source, ConnectionContext $context);
 }

src/Connector/ImportConnector.php

@@ -77,7 +77,11 @@ public function fetchAsync(string $source): Promise
         return \ScriptFUSION\Retry\retryAsync(
             $this->maxFetchAttempts,
             function () use ($source): Promise {
-                return \Amp\call($this->connector->fetchAsync($source, $this->connectionContext));
+                return \Amp\call(
+                    function () use ($source) {
+                        return $this->connector->fetchAsync($source, $this->connectionContext);
+                    }
+                );
             },
             $this->createExceptionHandler()
         );

test/MockFactory.php

@@ -6,7 +6,6 @@
 use Amp\Delayed;
 use Amp\Iterator;
 use Amp\Producer;
-use Amp\Promise;
 use Mockery\MockInterface;
 use ScriptFUSION\Porter\Connector\AsyncConnector;
 use ScriptFUSION\Porter\Connector\Connector;
@@ -40,9 +39,7 @@ public static function mockProvider()
                 ->andReturn(
                     \Mockery::mock(AsyncConnector::class)
                         ->shouldReceive('fetchAsync')
-                        ->andReturn(static function (): Promise {
-                            return new Delayed(0, 'foo');
-                        })
+                        ->andReturn(new Delayed(0, 'foo'))
                         ->getMock()
                 )
             ->getMock()