From 851166c9914e4ca5dbb334e47974edbb4e270371 Mon Sep 17 00:00:00 2001
From: Vincent Vermersch <Vinceveve@users.noreply.github.com>
Date: Wed, 30 Aug 2017 11:20:40 +0200
Subject: [PATCH] Update OnBackPressureBufferFile.php

---
 src/Rxnet/Operator/OnBackPressureBufferFile.php | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/Rxnet/Operator/OnBackPressureBufferFile.php b/src/Rxnet/Operator/OnBackPressureBufferFile.php
index 7fecfc3..2ed5632 100644
--- 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;
         }
     }
-}
\ No newline at end of file
+}