Shouldnt be using add like that w/rxjs 7

FirebaseExtended · Aug 25, 2021 · d2568bb · d2568bb
1 parent d41d3e4
commit d2568bb
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/storage/index.ts b/storage/index.ts
@@ -67,7 +67,11 @@ export function uploadBytesResumable(
 ): Observable<UploadTaskSnapshot> {
   return new Observable<UploadTaskSnapshot>(subscriber => {
     const task = _uploadBytesResumable(ref, data, metadata);
-    return fromTask(task).subscribe(subscriber).add(task.cancel);
+    const subscription = fromTask(task).subscribe(subscriber);
+    return function unsubscribe() {
+      subscription.unsubscribe();
+      task.cancel();
+    };
   }).pipe(shareReplay({ bufferSize: 1, refCount: true }));
 }