| 11 | return new Observable<UploadTaskSnapshot>(subscriber => { |
| 12 | const progress = (snap: UploadTaskSnapshot) => subscriber.next(snap); |
| 13 | const error = e => subscriber.error(e); |
| 14 | const complete = () => subscriber.complete(); |
| 15 | // emit the current snapshot, so they don't have to wait for state_changes |
| 16 | // to fire next... this is stale if the task is no longer running :( |