Fix #27: ErrorPlugin and sendAsyncRequest() incompatibility

Author: mekras

CHANGELOG.md

@@ -1,5 +1,12 @@
 # Change Log
 
+## Unreleased
+
+### Fixed
+
+- #27: ErrorPlugin and sendAsyncRequest() incompatibility
+
+
 ## 1.6 - 2016-09-12
 
 ### Changed

src/MultiRunner.php

@@ -93,13 +93,7 @@ public function wait(PromiseCore $targetCore = null)
                 }
 
                 if (CURLE_OK === $info['result']) {
-                    try {
-                        $core->fulfill();
-                    } catch (\Exception $e) {
-                        $core->reject(
-                            new RequestException($e->getMessage(), $core->getRequest(), $e)
-                        );
-                    }
+                    $core->fulfill();
                 } else {
                     $error = curl_error($core->getHandle());
                     $core->reject(new RequestException($error, $core->getRequest()));

src/PromiseCore.php

@@ -177,14 +177,19 @@ public function getException()
 
     /**
      * Fulfill promise.
-     *
-     * @throws \Exception from on fulfill handler.
      */
     public function fulfill()
     {
         $this->state = Promise::FULFILLED;
         $response = $this->responseBuilder->getResponse();
-        $response->getBody()->seek(0);
+        try {
+            $response->getBody()->seek(0);
+        } catch (\RuntimeException $e) {
+            $exception = new Exception\TransferException($e->getMessage(), $e->getCode(), $e);
+            $this->reject($exception);
+
+            return;
+        }
 
         while (count($this->onFulfilled) > 0) {
             $callback = array_shift($this->onFulfilled);