Simplify SizeLimitingInputStream

amphp · Nov 8, 2019 · c8777ca · c8777ca
1 parent 14302ed
commit c8777ca
Showing 1 changed file with 9 additions and 11 deletions.
diff --git a/src/Internal/SizeLimitingInputStream.php b/src/Internal/SizeLimitingInputStream.php
@@ -36,17 +36,15 @@ public function read(): Promise
 
         $promise = $this->source->read();
         $promise->onResolve(function ($error, $value) {
-            if ($error === null) {
-                if ($value !== null) {
-                    $this->bytesRead += \strlen($value);
-                    if ($this->bytesRead > $this->sizeLimit) {
-                        $this->exception = new ParseException(
-                            "Configured body size exceeded: {$this->bytesRead} bytes received, while the configured limit is {$this->sizeLimit} bytes",
-                            Status::PAYLOAD_TOO_LARGE
-                        );
-
-                        $this->source = null;
-                    }
+            if ($value !== null) {
+                $this->bytesRead += \strlen($value);
+                if ($this->bytesRead > $this->sizeLimit) {
+                    $this->exception = new ParseException(
+                        "Configured body size exceeded: {$this->bytesRead} bytes received, while the configured limit is {$this->sizeLimit} bytes",
+                        Status::PAYLOAD_TOO_LARGE
+                    );
+
+                    $this->source = null;
                 }
             }
         });