13745291876

Committed 09 Mar 2025 05:32AM UTC coverage: 97.4% (-0.05%) from 97.452%

Build # 13745291876

Build Type

push

github

Committed by

bordoley

Commit Message

create eventsources from async iterables

Coverage Stats

1047 of 1143 branches covered (91.6%)

Branch coverage included in aggregate %.

40 of 43 new or added lines in 3 files covered. (93.02%)

30 existing lines in 3 files now uncovered.

5695 of 5779 relevant lines covered (98.55%)

7234.88 hits per line

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

70.59

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

import { AsyncIterableLike } from "../../../computations.js";
import { error, returns } from "../../../functions.js";
import {
  DisposableLike_dispose,
  DisposableLike_isDisposed,
  EventListenerLike,
  EventListenerLike_notify,
} from "../../../utils.js";
import type * as EventSource from "../../EventSource.js";
import EventSource_create from "./EventSource.create.js";

const EventSource_fromAsyncIterable: EventSource.Signature["fromAsyncIterable"] =
  /*@__PURE__*/ returns((iter: AsyncIterableLike) =>
    EventSource_create(async (listener: EventListenerLike) => {
      try {
        for await (const v of iter) {
          if (listener[DisposableLike_isDisposed]) {
            break;
          }

          listener[EventListenerLike_notify](v);

          if (listener[DisposableLike_isDisposed]) {
            break;
          }
        }
        listener[DisposableLike_dispose]();
      } catch (e) {
        listener[DisposableLike_dispose](error(e));
      }
    }),
  ) as EventSource.Signature["fromAsyncIterable"];

export default EventSource_fromAsyncIterable;

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

bordoley / reactive-js / 13745291876

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