d9ae709b-3c27-4b69-b125-b8b80b54f90b

import { BehaviorSubject } from 'rxjs';
import { ThyGlobalMessageConfig } from '../message.config';
import { ThyAbstractMessageRef } from './abstract-message-ref';

/**
 * @internal
 */
export class ThyAbstractMessageQueue<TReferences extends ThyAbstractMessageRef = ThyAbstractMessageRef> {
    queues$ = new BehaviorSubject<TReferences[]>([]);

    protected defaultConfig: ThyGlobalMessageConfig;

    get queues() {
        return this.queues$.getValue();
    }

    constructor(defaultConfig: ThyGlobalMessageConfig) {
        this.defaultConfig = defaultConfig;
    }

    add(messageRef: TReferences) {
        const queues = this.queues$.getValue();
        if (this.queues.length >= this.defaultConfig.maxStack) {
            const closedRef = queues.shift();
            closedRef.close();
        }
        this.queues$.next([...queues, messageRef]);
    }

    remove(id: string) {
        if (!id) {
            this.queues.forEach(item => item.close());
            this.queues$.next([]);
        } else {
            const removeItem = this.queues.find(item => item.id === id);
            removeItem?.close();
            const afterRemovedQueues = this.queues.filter(item => item.id !== id);
            this.queues$.next(afterRemovedQueues);
        }
    }
}

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

atinc / ngx-tethys / d9ae709b-3c27-4b69-b125-b8b80b54f90b

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