d9ae709b-3c27-4b69-b125-b8b80b54f90b

import { Inject, Injectable } from '@angular/core';
import { ThyAbstractMessageQueue } from 'ngx-tethys/message';
import { map, shareReplay } from 'rxjs/operators';
import { ThyNotifyRef } from './notify-ref';
import { ThyGlobalNotifyConfig, THY_NOTIFY_DEFAULT_CONFIG, THY_NOTIFY_DEFAULT_CONFIG_VALUE } from './notify.config';

/**
 * @internal
 */
@Injectable({
    providedIn: 'root'
})
export class ThyNotifyQueue extends ThyAbstractMessageQueue<ThyNotifyRef> {
    topLeftQueues$ = this.queues$.pipe(
        map(queues => queues.filter(item => item.config.placement === 'topLeft')),
        shareReplay()
    );

    topRightQueues$ = this.queues$.pipe(
        map(queues => queues.filter(item => item.config.placement === 'topRight')),
        shareReplay()
    );

    bottomLeftQueues$ = this.queues$.pipe(
        map(queues => queues.filter(item => item.config.placement === 'bottomLeft')),
        shareReplay()
    );

    bottomRightQueues$ = this.queues$.pipe(
        map(queues => queues.filter(item => item.config.placement === 'bottomRight')),
        shareReplay()
    );

    constructor(@Inject(THY_NOTIFY_DEFAULT_CONFIG) defaultConfig: ThyGlobalNotifyConfig) {
        super({
            ...THY_NOTIFY_DEFAULT_CONFIG_VALUE,
            ...defaultConfig
        });
    }
}

1	import { Inject, Injectable } from '@angular/core';
2	import { ThyAbstractMessageQueue } from 'ngx-tethys/message';
3	import { map, shareReplay } from 'rxjs/operators';
4	import { ThyNotifyRef } from './notify-ref';
5	import { ThyGlobalNotifyConfig, THY_NOTIFY_DEFAULT_CONFIG, THY_NOTIFY_DEFAULT_CONFIG_VALUE } from './notify.config';
6
7	/**
8	* @internal
9	*/	1✔
10	@Injectable({
11	providedIn: 'root'	×
12	})
13	export class ThyNotifyQueue extends ThyAbstractMessageQueue<ThyNotifyRef> {
14	topLeftQueues$ = this.queues$.pipe(
15	map(queues => queues.filter(item => item.config.placement === 'topLeft')),	×
16	shareReplay()	×
17	);	×
18		×
19	topRightQueues$ = this.queues$.pipe(
20	map(queues => queues.filter(item => item.config.placement === 'topRight')),	1✔
21	shareReplay()
22	);
23
24	bottomLeftQueues$ = this.queues$.pipe(	1✔
25	map(queues => queues.filter(item => item.config.placement === 'bottomLeft')),
26	shareReplay()
27	);
28
29	bottomRightQueues$ = this.queues$.pipe(
30	map(queues => queues.filter(item => item.config.placement === 'bottomRight')),
31	shareReplay()
32	);
33
34	constructor(@Inject(THY_NOTIFY_DEFAULT_CONFIG) defaultConfig: ThyGlobalNotifyConfig) {
35	super({
36	...THY_NOTIFY_DEFAULT_CONFIG_VALUE,
37	...defaultConfig
38	});
39	}
40	}

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