Update OnBackPressureBufferFile.php

Domraider · Aug 30, 2017 · 851166c · 851166c
1 parent dfa3256
commit 851166c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Rxnet/Operator/OnBackPressureBufferFile.php b/src/Rxnet/Operator/OnBackPressureBufferFile.php
@@ -104,8 +104,7 @@ function ($next) {
 
 
                 },
-                [$this->subject, 'onError'],
-                [$this->subject, 'onCompleted']
+                [$this->subject, 'onError']
             ),
             $scheduler
         );
@@ -130,6 +129,7 @@ public function request()
         // Queue is finished we can return to live stream
         if ($this->queue->isEmpty()) {
             $this->pending = self::BUFFER_EMPTY;
+            $this->subject->onCompleted();
             return;
         }
         // Take element in order they have been inserted
@@ -159,4 +159,4 @@ protected function scanDir() {
             $this->pending = self::BUFFER_RESTORED;
         }
     }
-}
+}