13892587551

Committed 17 Mar 2025 05:57AM UTC coverage: 95.01% (-0.7%) from 95.738%

Build Type

push

github

Committed by

Commit Message

first steps towards removing multicast observable

Coverage Stats

1094 of 1236 branches covered (88.51%)

Branch coverage included in aggregate %.

25 of 73 new or added lines in 7 files covered. (34.25%)

7 existing lines in 1 file now uncovered.

6180 of 6420 relevant lines covered (96.26%)

3142.77 hits per line

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

29.41

/src/computations/EventSource/__private__/EventSource.fromAsyncIterable.ts

1	import { AsyncIterableLike } from "../../../computations.js";
2	import { error, returns } from "../../../functions.js";	14✔
3	import {	14✔
4	DisposableLike_dispose,
5	DisposableLike_isDisposed,
6	EventListenerLike,
7	EventListenerLike_notify,
8	} from "../../../utils.js";
9	import type * as EventSource from "../../EventSource.js";
10	import EventSource_create from "./EventSource.create.js";	14✔
11
12	const EventSource_fromAsyncIterable: EventSource.Signature["fromAsyncIterable"] =
13	/@__PURE__/ returns((iter: AsyncIterableLike) =>	14✔
UNCOV 14	EventSource_create(async (listener: EventListenerLike) => {	×
UNCOV 15	try {	×
UNCOV 16	for await (const v of iter) {	×
UNCOV 17	if (listener[DisposableLike_isDisposed]) {	×
18	break;	×
19	}
20
UNCOV 21	listener[EventListenerLike_notify](v);	×
22
UNCOV 23	if (listener[DisposableLike_isDisposed]) {	×
24	break;	×
25	}
26	}
UNCOV 27	listener[DisposableLike_dispose]();	×
28	} catch (e) {
29	listener[DisposableLike_dispose](error(e));	×
30	}
31	}),
32	) as EventSource.Signature["fromAsyncIterable"];
33
34	export default EventSource_fromAsyncIterable;	14✔