NikolayMakhonin / async-utils / #10

Build # #10

Build Type

push

Committed by

Commit Message

<a href="https://github.com/NikolayMakhonin/async-utils/commit/<a class=hub.com/NikolayMakhonin/async-utils/commit/1abd1f8415e357a4583c72ec6594e737182bcb41">1abd1f841<a href="https://github.com/NikolayMakhonin/async-utils/commit/1abd1f8415e357a4583c72ec6594e737182bcb41">">Merge </a><a class="double-link" href="https://github.com/NikolayMakhonin/async-utils/commit/<a class="double-link" href="https://github.com/NikolayMakhonin/async-utils/commit/995f6ce3646bbc637ced3f8b0afa88fb4f5c499c">995f6ce36</a>">995f6ce36</a><a href="https://github.com/NikolayMakhonin/async-utils/commit/1abd1f8415e357a4583c72ec6594e737182bcb41"> into 7444b8c09">7444b8c09</a>

Run Details

162 of 242 branches covered (66.94%)

Branch coverage included in aggregate %.

236 of 236 new or added lines in 13 files covered. (100.0%)

345 of 444 relevant lines covered (77.7%)

24675.46 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

39.22

/src/abort-controller-fast/promiseToAbortable.ts

import {IAbortSignalFast, IUnsubscribe} from '@flemist/abort-controller-fast'

export function promiseToAbortable<T>(
  abortSignal: IAbortSignalFast|null,
  promise: Promise<T>,
): Promise<T> {
  return new Promise<T>(function executor(resolve, reject) {
    if (abortSignal && abortSignal.aborted) {
      reject(abortSignal.reason)
      return
    }

    let unsubscribe: IUnsubscribe
    function onResolve(value: T) {
      if (unsubscribe) {
        unsubscribe()
      }
      resolve(value)
    }

    let rejected: boolean
    function onReject(value: T) {
      if (rejected) {
        return
      }

      rejected = true

      if (unsubscribe) {
        unsubscribe()
      }

      reject(value)
    }

    promise
      .then(onResolve)
      .catch(onReject)

    if (abortSignal) {
      unsubscribe = abortSignal.subscribe(onReject)
    }
  })
}

1	import {IAbortSignalFast, IUnsubscribe} from '@flemist/abort-controller-fast'
2		136,332✔
3	export function promiseToAbortable<T>(	136,332!
4	abortSignal: IAbortSignalFast\|null,	×
5	promise: Promise<T>,	×
6	): Promise<T> {
7	return new Promise<T>(function executor(resolve, reject) {	68,544✔
8	if (abortSignal && abortSignal.aborted) {	68,544!
9	reject(abortSignal.reason)	136,332!
10	return	×
11	}
12		136,332✔
13	let unsubscribe: IUnsubscribe
14	function onResolve(value: T) {
15	if (unsubscribe) {	68,544!
16	unsubscribe()	×
17	}	×
18	resolve(value)	68,544✔
19	}	×
20		×
21	let rejected: boolean	×
22	function onReject(value: T) {
23	if (rejected) {	×
24	return	×
25	}	136,332✔
26
27	rejected = true	×
28		136,332!
29	if (unsubscribe) {	×
30	unsubscribe()	×
31	}
32
33	reject(value)	×
34	}
35
36	promise	68,544✔
37	.then(onResolve)
38	.catch(onReject)
39
40	if (abortSignal) {	68,544!
41	unsubscribe = abortSignal.subscribe(onReject)	×
42	}
43	})
44	}

NikolayMakhonin / async-utils / #10

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous