• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

bordoley / reactive-js / 13745291876

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

push

github

bordoley
create eventsources from async iterables

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
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✔
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc