14278092116

Committed 05 Apr 2025 03:32AM UTC coverage: 88.48% (-6.7%) from 95.167%

Build # 14278092116

Build Type

push

github

Committed by

bordoley

Commit Message

tests

Run Details

929 of 1256 branches covered (73.96%)

Branch coverage included in aggregate %.

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

229 existing lines in 27 files now uncovered.

6037 of 6617 relevant lines covered (91.23%)

421.48 hits per line

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

90.0

/src/node/NodeReadable.ts

import { Readable } from "stream";
import * as Producer from "../computations/Producer.js";
import { ProducerWithSideEffectsLike } from "../computations.js";
import { Factory, bindMethod, pipe } from "../functions.js";
import {
  EventListenerLike_notify,
  FlowControllerLike_addOnReadyListener,
  FlowControllerLike_isReady,
  SinkLike_complete,
} from "../utils.js";
import * as NodeStream from "./NodeStream.js";

interface NodeReadable {
  create(factory: Factory<Readable>): ProducerWithSideEffectsLike<Uint8Array>;
}

type Signature = NodeReadable;

export const create: Signature["create"] = factory =>
  Producer.create(consumer => {
    const readable = factory();
    pipe(readable, NodeStream.addTo(consumer), NodeStream.add(consumer));

    readable.pause();

    consumer[FlowControllerLike_addOnReadyListener](
      bindMethod(readable, "resume"),
    );

    const onData = (data: Uint8Array) => {
      consumer[EventListenerLike_notify](data);

      if (!consumer[FlowControllerLike_isReady]) {
        readable.pause();
      }
    };
    readable.on("data", onData);

    readable.on("end", bindMethod(consumer, SinkLike_complete));

    if (consumer[FlowControllerLike_isReady]) {
      readable.resume();
    }
  });

1	import { Readable } from "stream";
2	import * as Producer from "../computations/Producer.js";	1✔
3	import { ProducerWithSideEffectsLike } from "../computations.js";
4	import { Factory, bindMethod, pipe } from "../functions.js";	1✔
5	import {	1✔
6	EventListenerLike_notify,
7	FlowControllerLike_addOnReadyListener,
8	FlowControllerLike_isReady,
9	SinkLike_complete,
10	} from "../utils.js";
11	import * as NodeStream from "./NodeStream.js";	1✔
12
13	interface NodeReadable {
14	create(factory: Factory<Readable>): ProducerWithSideEffectsLike<Uint8Array>;
15	}
16
17	type Signature = NodeReadable;
18
19	export const create: Signature["create"] = factory =>	1✔
20	Producer.create(consumer => {	3✔
21	const readable = factory();	3✔
22	pipe(readable, NodeStream.addTo(consumer), NodeStream.add(consumer));	3✔
23
24	readable.pause();	3✔
25
26	consumer[FlowControllerLike_addOnReadyListener](	3✔
27	bindMethod(readable, "resume"),
28	);
29
30	const onData = (data: Uint8Array) => {	3✔
31	consumer[EventListenerLike_notify](data);	5✔
32
33	if (!consumer[FlowControllerLike_isReady]) {	5!
UNCOV 34	readable.pause();	×
35	}
36	};
37	readable.on("data", onData);	3✔
38
39	readable.on("end", bindMethod(consumer, SinkLike_complete));	3✔
40
41	if (consumer[FlowControllerLike_isReady]) {	3✔
42	readable.resume();	3✔
43	}
44	});

bordoley / reactive-js / 14278092116

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