From d2250c91e425f7d4d5b876f98bb7f264d9d82300 Mon Sep 17 00:00:00 2001
From: James Daniels <jamesdaniels@google.com>
Date: Tue, 24 Nov 2020 13:32:54 -0500
Subject: [PATCH] fix(storage): unsubscribing from the upload progress will not
 cancel and added replay

---
 src/storage/observable/fromTask.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/storage/observable/fromTask.ts b/src/storage/observable/fromTask.ts
index ae4d8ec94..a4442dd1e 100644
--- a/src/storage/observable/fromTask.ts
+++ b/src/storage/observable/fromTask.ts
@@ -1,4 +1,5 @@
 import { Observable } from 'rxjs';
+import { shareReplay } from 'rxjs/operators';
 import { UploadTask, UploadTaskSnapshot } from '../interfaces';
 
 export function fromTask(task: UploadTask) {
@@ -13,6 +14,7 @@ export function fromTask(task: UploadTask) {
       progress(task.snapshot);
       complete();
     });
-    return () => task.cancel();
-  });
+  }).pipe(
+    shareReplay({ bufferSize: 1, refCount: false })
+  );
 }