| 12345678910111213141516171819202122232425262728 |
- export class AbortablePromise<T> {
- promise: Promise<T>
- private _reject: ((res?: any) => void) | null = null
- constructor(executor: (resolve: (value: T | PromiseLike<T>) => void, reject: (reason?: any) => void) => void) {
- this.promise = new Promise<T>((resolve, reject) => {
- executor(resolve, reject)
- this._reject = reject // 保存reject方法的引用,以便在abort时调用
- })
- }
- // 提供abort方法来中止Promise
- abort(error?: any) {
- if (this._reject) {
- this._reject(error) // 调用reject方法来中止Promise
- }
- }
- then<TResult1 = T, TResult2 = never>(
- onfulfilled?: ((value: T) => TResult1 | PromiseLike<TResult1>) | undefined | null,
- onrejected?: ((reason: any) => TResult2 | PromiseLike<TResult2>) | undefined | null
- ): Promise<TResult1 | TResult2> {
- return this.promise.then(onfulfilled, onrejected)
- }
- catch<TResult = never>(onrejected?: ((reason: any) => TResult | PromiseLike<TResult>) | undefined | null): Promise<T | TResult> {
- return this.promise.catch(onrejected)
- }
- }
|