Class Task

packages/firebase-storage/index.ios.ts:90–195

}

export class Task implements ITask {
	_native: FIRStorageUploadTask | FIRStorageDownloadTask;

	static fromNative(value: FIRStorageUploadTask | FIRStorageDownloadTask) {
		if (value instanceof FIRStorageUploadTask || value instanceof FIRStorageDownloadTask) {
			const task = new Task();
			task._native = value;
			return task;
		}
		return null;
	}

	get native() {
		return this._native;
	}

	get ios() {
		return this.native;
	}

	get snapshot(): TaskSnapshot {
		return TaskSnapshot.fromNative(this.native.snapshot);
	}

	cancel(): boolean {
		this.native?.cancel();
		return this.native.snapshot.progress.cancelled;
	}

	on(event: TaskEvent, nextOrObserver?: TaskSnapshotObserver | ((a: TaskSnapshot) => any), error?: (a: FirebaseError) => any, complete?: () => void) {
		if (event !== TaskEvent.STATE_CHANGED) {
			return;
		}

		if (nextOrObserver) {
			if (typeof nextOrObserver === 'function') {
				this.native.observeStatusHandler(FIRStorageTaskStatus.Progress, (snapshot) => {
					nextOrObserver(TaskSnapshot.fromNative(snapshot));
				});

				this.native.observeStatusHandler(FIRStorageTaskStatus.Pause, (snapshot) => {
					nextOrObserver(TaskSnapshot.fromNative(snapshot));
				});

				this.native.observeStatusHandler(FIRStorageTaskStatus.Resume, (snapshot) => {
					nextOrObserver(TaskSnapshot.fromNative(snapshot));
				});
			} else if (typeof nextOrObserver === 'object') {
				this.native.observeStatusHandler(FIRStorageTaskStatus.Progress, (snapshot) => {
					nextOrObserver?.next(TaskSnapshot.fromNative(snapshot));
				});

				this.native.observeStatusHandler(FIRStorageTaskStatus.Pause, (snapshot) => {
					nextOrObserver?.next(TaskSnapshot.fromNative(snapshot));
				});

				this.native.observeStatusHandler(FIRStorageTaskStatus.Resume, (snapshot) => {
					nextOrObserver?.next(TaskSnapshot.fromNative(snapshot));