diff --git a/src/storage/observable/fromTask.ts b/src/storage/observable/fromTask.ts
index 8b485eae1..ae4d8ec94 100644
--- a/src/storage/observable/fromTask.ts
+++ b/src/storage/observable/fromTask.ts
@@ -6,7 +6,10 @@ export function fromTask(task: UploadTask) {
     const progress = (snap: UploadTaskSnapshot) => subscriber.next(snap);
     const error = e => subscriber.error(e);
     const complete = () => subscriber.complete();
-    task.on('state_changed', progress, error, () => {
+    task.on('state_changed', progress, (e) => {
+      progress(task.snapshot);
+      error(e);
+    }, () => {
       progress(task.snapshot);
       complete();
     });