21877149956

Committed 10 Feb 2026 06:20PM UTC coverage: 85.292% (-9.1%) from 94.396%

Build # 21877149956

Build Type

Pull #28

github

Committed by

web-flow

Commit Message

Merge 1d0a1ad0d into 828e39903

Pull Request Pull Request #28: TypeScript and event dispatching pipeline refactoring

Run Details

673 of 1010 branches covered (66.63%)

935 of 1061 new or added lines in 68 files covered. (88.12%)

49 existing lines in 13 files now uncovered.

1270 of 1489 relevant lines covered (85.29%)

33.79 hits per line

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

75.0

/src/workers/protocol.ts

import type { MessagePort } from 'node:worker_threads';

export interface IWorkerData {
        projectionPort: MessagePort,
        viewPort: MessagePort
}

export const isWorkerData = (obj: unknown): obj is IWorkerData =>
        typeof obj === 'object'
        && obj !== null
        && 'projectionPort' in obj
        && !!obj.projectionPort
        && 'viewPort' in obj
        && !!obj.viewPort;

export type WorkerInitMessage = { type: 'ready' };

export const isWorkerInitMessage = (msg: unknown): msg is WorkerInitMessage =>
        typeof msg === 'object'
        && msg !== null
        && 'type' in msg
        && msg.type === 'ready';


1	import type { MessagePort } from 'node:worker_threads';
2
3	export interface IWorkerData {
4	projectionPort: MessagePort,
5	viewPort: MessagePort
6	}
7
8	export const isWorkerData = (obj: unknown): obj is IWorkerData =>	2✔
NEW 9	typeof obj === 'object'	×
10	&& obj !== null
11	&& 'projectionPort' in obj
12	&& !!obj.projectionPort
13	&& 'viewPort' in obj
14	&& !!obj.viewPort;
15
16	export type WorkerInitMessage = { type: 'ready' };
17
18	export const isWorkerInitMessage = (msg: unknown): msg is WorkerInitMessage =>	2✔
19	typeof msg === 'object'	14✔
20	&& msg !== null
21	&& 'type' in msg
22	&& msg.type === 'ready';
23

snatalenko / node-cqrs / 21877149956

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