13617659096

Committed 02 Mar 2025 05:19PM UTC coverage: 96.572% (-0.4%) from 96.986%

Build # 13617659096

Build Type

push

github

Committed by

bordoley

Commit Message

Add helper Observable modules for when working with HOFs

Coverage Stats

932 of 1042 branches covered (89.44%)

Branch coverage included in aggregate %.

29 of 57 new or added lines in 3 files covered. (50.88%)

5210 of 5318 relevant lines covered (97.97%)

5967.36 hits per line

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

0.0

/src/concurrent/DeferredObservable.ts

import {
  ComputationWithSideEffectsModule,
  DeferredComputationModule,
  DeferredReactiveComputationModule,
} from "../computations.js";
import { DeferredObservableLike } from "../concurrent.js";
import { ObservableComputationFor } from "./Observable.js";
import * as Observable from "./Observable.js";

export interface DeferredObservableModule
  extends DeferredComputationModule<
      ObservableComputationFor<DeferredObservableLike>
    >,
    DeferredReactiveComputationModule<
      ObservableComputationFor<DeferredObservableLike>
    >,
    ComputationWithSideEffectsModule<
      ObservableComputationFor<DeferredObservableLike>
    >,
    DeferredComputationModule<
      ObservableComputationFor<DeferredObservableLike>
    > {}

export type Signature = DeferredObservableModule;

export const buffer: Signature["buffer"] =
  Observable.buffer as Signature["buffer"];
export const catchError: Signature["catchError"] =
  Observable.catchError as Signature["catchError"];
export const concatAll: Signature["concatAll"] =
  Observable.concatAll as Signature["concatAll"];
export const concatMany: Signature["concatMany"] =
  Observable.concatMany as Signature["concatMany"];
export const decodeWithCharset: Signature["decodeWithCharset"] =
  Observable.decodeWithCharset as Signature["decodeWithCharset"];
export const distinctUntilChanged: Signature["distinctUntilChanged"] =
  Observable.distinctUntilChanged as Signature["distinctUntilChanged"];
export const empty: Signature["empty"] = Observable.empty;
export const forEach: Signature["forEach"] = Observable.forEach;
export const fromIterable: Signature["fromIterable"] =
  Observable.fromIterable as Signature["fromIterable"];
export const fromReadonlyArray: Signature["fromReadonlyArray"] =
  Observable.fromReadonlyArray;
export const fromValue: Signature["fromValue"] = Observable.fromValue;
export const generate: Signature["generate"] = Observable.generate;
export const keep: Signature["keep"] = Observable.keep as Signature["keep"];
export const map: Signature["map"] = Observable.map as Signature["map"];
export const pairwise: Signature["pairwise"] =
  Observable.pairwise as Signature["pairwise"];
export const raise: Signature["raise"] = Observable.raise;
export const repeat: Signature["repeat"] =
  Observable.repeat as Signature["repeat"];
export const retry: Signature["retry"] = Observable.retry as Signature["retry"];
export const scan: Signature["scan"] = Observable.scan as Signature["scan"];
export const skipFirst: Signature["skipFirst"] =
  Observable.skipFirst as Signature["skipFirst"];
export const takeFirst: Signature["takeFirst"] =
  Observable.takeFirst as Signature["takeFirst"];
export const takeLast: Signature["takeLast"] =
  Observable.takeLast as Signature["takeLast"];
export const takeWhile: Signature["takeWhile"] =
  Observable.takeWhile as Signature["takeWhile"];
export const throwIfEmpty: Signature["throwIfEmpty"] =
  Observable.throwIfEmpty as Signature["throwIfEmpty"];

1	import {
2	ComputationWithSideEffectsModule,
3	DeferredComputationModule,
4	DeferredReactiveComputationModule,
5	} from "../computations.js";
6	import { DeferredObservableLike } from "../concurrent.js";
7	import { ObservableComputationFor } from "./Observable.js";
8	import * as Observable from "./Observable.js";
9
10	export interface DeferredObservableModule
11	extends DeferredComputationModule<
12	ObservableComputationFor<DeferredObservableLike>
13	>,
14	DeferredReactiveComputationModule<
15	ObservableComputationFor<DeferredObservableLike>
16	>,
17	ComputationWithSideEffectsModule<
18	ObservableComputationFor<DeferredObservableLike>
19	>,
20	DeferredComputationModule<
21	ObservableComputationFor<DeferredObservableLike>
22	> {}
23
24	export type Signature = DeferredObservableModule;
25
26	export const buffer: Signature["buffer"] =
NEW 27	Observable.buffer as Signature["buffer"];	×
28	export const catchError: Signature["catchError"] =
NEW 29	Observable.catchError as Signature["catchError"];	×
30	export const concatAll: Signature["concatAll"] =
NEW 31	Observable.concatAll as Signature["concatAll"];	×
32	export const concatMany: Signature["concatMany"] =
NEW 33	Observable.concatMany as Signature["concatMany"];	×
34	export const decodeWithCharset: Signature["decodeWithCharset"] =
NEW 35	Observable.decodeWithCharset as Signature["decodeWithCharset"];	×
36	export const distinctUntilChanged: Signature["distinctUntilChanged"] =
NEW 37	Observable.distinctUntilChanged as Signature["distinctUntilChanged"];	×
NEW 38	export const empty: Signature["empty"] = Observable.empty;	×
NEW 39	export const forEach: Signature["forEach"] = Observable.forEach;	×
40	export const fromIterable: Signature["fromIterable"] =
NEW 41	Observable.fromIterable as Signature["fromIterable"];	×
42	export const fromReadonlyArray: Signature["fromReadonlyArray"] =
NEW 43	Observable.fromReadonlyArray;	×
NEW 44	export const fromValue: Signature["fromValue"] = Observable.fromValue;	×
NEW 45	export const generate: Signature["generate"] = Observable.generate;	×
NEW 46	export const keep: Signature["keep"] = Observable.keep as Signature["keep"];	×
NEW 47	export const map: Signature["map"] = Observable.map as Signature["map"];	×
48	export const pairwise: Signature["pairwise"] =
NEW 49	Observable.pairwise as Signature["pairwise"];	×
NEW 50	export const raise: Signature["raise"] = Observable.raise;	×
51	export const repeat: Signature["repeat"] =
NEW 52	Observable.repeat as Signature["repeat"];	×
NEW 53	export const retry: Signature["retry"] = Observable.retry as Signature["retry"];	×
NEW 54	export const scan: Signature["scan"] = Observable.scan as Signature["scan"];	×
55	export const skipFirst: Signature["skipFirst"] =
NEW 56	Observable.skipFirst as Signature["skipFirst"];	×
57	export const takeFirst: Signature["takeFirst"] =
NEW 58	Observable.takeFirst as Signature["takeFirst"];	×
59	export const takeLast: Signature["takeLast"] =
NEW 60	Observable.takeLast as Signature["takeLast"];	×
61	export const takeWhile: Signature["takeWhile"] =
NEW 62	Observable.takeWhile as Signature["takeWhile"];	×
63	export const throwIfEmpty: Signature["throwIfEmpty"] =
NEW 64	Observable.throwIfEmpty as Signature["throwIfEmpty"];	×

bordoley / reactive-js / 13617659096

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