Update OnBackPressureBufferFile.php

Domraider · Sep 4, 2017 · af81536 · af81536
1 parent 9de00fd
commit af81536
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/Rxnet/Operator/OnBackPressureBufferFile.php b/src/Rxnet/Operator/OnBackPressureBufferFile.php
@@ -107,7 +107,12 @@ function ($next) {
                 },
                 [$this->subject, 'onError'],
                 function() {
-                  $this->sourceCompleted = true;
+                    if(!$this->pending) {
+                        $this->subject->onCompleted();
+                    }
+                    else {
+                        $this->sourceCompleted = true;
+                    }
                 }
             ),
             $scheduler