68ef226c-f83e-44c1-b8ed-e420a83c5d84

Committed 28 May 2025 10:31AM UTC coverage: 10.352% (-80.0%) from 90.316%

Build Type

circleci

Committed by

Commit Message

chore: xxx

Run Details

132 of 6823 branches covered (1.93%)

Branch coverage included in aggregate %.

10 of 14 new or added lines in 1 file covered. (71.43%)

11648 existing lines in 344 files now uncovered.

2078 of 14525 relevant lines covered (14.31%)

6.69 hits per line

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

0.0

/src/message/abstract/abstract-message-queue.service.ts

1	import { BehaviorSubject } from 'rxjs';
2	import { ThyGlobalMessageConfig } from '../message.config';
3	import { IThyAbstractMessageQueue, ThyAbstractMessageRef } from './abstract-message-ref';
4
5	/**
6	* @internal
UNCOV 7	*/	×
8	export class ThyAbstractMessageQueue<TReferences extends ThyAbstractMessageRef = ThyAbstractMessageRef>
9	implements IThyAbstractMessageQueue
UNCOV 10	{	×
UNCOV 11	queues$ = new BehaviorSubject<TReferences[]>([]);	×
12
13	protected defaultConfig: ThyGlobalMessageConfig;
UNCOV 14		×
UNCOV 15	get queues(): TReferences[] {	×
UNCOV 16	return this.queues$.getValue();	×
UNCOV 17	}	×
18
UNCOV 19	constructor(defaultConfig: ThyGlobalMessageConfig) {	×
20	this.defaultConfig = defaultConfig;
21	}
UNCOV 22		×
UNCOV 23	add(messageRef: TReferences) {	×
UNCOV 24	const queues = this.queues$.getValue();	×
25	if (this.queues.length >= this.defaultConfig.maxStack) {
26	const closedRef = queues.shift();
UNCOV 27	closedRef.close();	×
UNCOV 28	}	×
UNCOV 29	this.queues$.next([...queues, messageRef]);	×
UNCOV 30	}	×
31
32	remove(id: string) {
33	if (!id) {
34	this.queues.forEach(item => item.close());
35	this.queues$.next([]);
36	} else {
37	const removeItem = this.queues.find(item => item.id === id);
38	removeItem?.close();
39	const afterRemovedQueues = this.queues.filter(item => item.id !== id);
40	this.queues$.next(afterRemovedQueues);
41	}
42	}
43	}