13254191417

Committed 11 Feb 2025 01:45AM UTC coverage: 97.866% (-0.2%) from 98.106%

Build # 13254191417

Build Type

push

github

Committed by

bordoley

Commit Message

simplify animationGroup api

Coverage Stats

721 of 773 branches covered (93.27%)

Branch coverage included in aggregate %.

23 of 24 new or added lines in 2 files covered. (95.83%)

7 existing lines in 2 files now uncovered.

4185 of 4240 relevant lines covered (98.7%)

9872.67 hits per line

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

38.46

/src/concurrent/Streamable/__private__/Streamable.eventHandler.ts

import { DeferredObservableLike, StreamableLike } from "../../../concurrent.js";
import { Function1, compose, pipe } from "../../../functions.js";
import { BackpressureStrategy } from "../../../utils.js";
import * as Observable from "../../Observable.js";
import type * as Streamable from "../../Streamable.js";
import Streamable_create from "./Streamable.create.js";

const Streamable_eventHandler: Streamable.Signature["eventHandler"] = (<
  TEventType,
>(
  op: Function1<TEventType, DeferredObservableLike<unknown>>,
  options: {
    readonly mode?: "switching" | "blocking" | "queueing";
    readonly backpressureStrategy?: BackpressureStrategy;
    readonly capacity?: number;
  } = {},
): StreamableLike<TEventType, boolean> => {
  const { mode } = options;
  const boundedOP = compose(
    op,
    Observable.ignoreElements(),
    Observable.startWith<boolean>(true),
    Observable.endWith<boolean>(false),
  );

  return Streamable_create<TEventType, boolean>(
    compose(
      mode === "switching"
        ? Observable.switchMap<TEventType, boolean>(boundedOP, {
            innerType: Observable.DeferredObservableWithSideEffectsType,
          })
        : mode === "blocking"
          ? Observable.exhaustMap<TEventType, boolean>(boundedOP, {
              innerType: Observable.DeferredObservableWithSideEffectsType,
            })
          : Observable.mergeMap<TEventType, boolean>(boundedOP, {
              ...options,
              concurrency: 1,
              innerType: Observable.DeferredObservableWithSideEffectsType,
            }),
      Observable.mergeWith<boolean>(pipe(false, Observable.fromValue())),
    ),
  );
}) as Streamable.Signature["eventHandler"];

export default Streamable_eventHandler;

1	import { DeferredObservableLike, StreamableLike } from "../../../concurrent.js";
2	import { Function1, compose, pipe } from "../../../functions.js";	1✔
3	import { BackpressureStrategy } from "../../../utils.js";
4	import * as Observable from "../../Observable.js";	1✔
5	import type * as Streamable from "../../Streamable.js";
6	import Streamable_create from "./Streamable.create.js";	1✔
7
8	const Streamable_eventHandler: Streamable.Signature["eventHandler"] = (<	1✔
9	TEventType,
10	>(
11	op: Function1<TEventType, DeferredObservableLike<unknown>>,
12	options: {	×
13	readonly mode?: "switching" \| "blocking" \| "queueing";
14	readonly backpressureStrategy?: BackpressureStrategy;
15	readonly capacity?: number;
16	} = {},
17	): StreamableLike<TEventType, boolean> => {
UNCOV 18	const { mode } = options;	×
UNCOV 19	const boundedOP = compose(	×
20	op,
21	Observable.ignoreElements(),
22	Observable.startWith<boolean>(true),
23	Observable.endWith<boolean>(false),
24	);
25
NEW 26	return Streamable_create<TEventType, boolean>(	×
27	compose(
28	mode === "switching"	×
29	? Observable.switchMap<TEventType, boolean>(boundedOP, {
30	innerType: Observable.DeferredObservableWithSideEffectsType,
31	})
32	: mode === "blocking"	×
33	? Observable.exhaustMap<TEventType, boolean>(boundedOP, {
34	innerType: Observable.DeferredObservableWithSideEffectsType,
35	})
36	: Observable.mergeMap<TEventType, boolean>(boundedOP, {
37	...options,
38	concurrency: 1,
39	innerType: Observable.DeferredObservableWithSideEffectsType,
40	}),
41	Observable.mergeWith<boolean>(pipe(false, Observable.fromValue())),
42	),
43	);
44	}) as Streamable.Signature["eventHandler"];
45
46	export default Streamable_eventHandler;	1✔

bordoley / reactive-js / 13254191417

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