d9ae709b-3c27-4b69-b125-b8b80b54f90b

import { Subject } from 'rxjs';
import { OnDestroy } from '@angular/core';
import { Constructor } from './constructor';

export interface ThyUnsubscribe extends OnDestroy {
    ngUnsubscribe$: Subject<void>;
}

/** Mixin to augment a directive with a `disableRipple` property. */
export function mixinUnsubscribe<T extends Constructor<{}>>(base: T): Constructor<ThyUnsubscribe> & T {
    return class Mixin extends base {
        ngUnsubscribe$ = new Subject<void>();

        constructor(...args: any[]) {
            super(...args);
        }

        ngUnsubscribeReinitialize() {
            this.ngUnsubscribe$.next();
            this.ngUnsubscribe$.complete();
            this.ngUnsubscribe$ = new Subject();
        }

        ngOnDestroy() {
            this.ngUnsubscribe$.next();
            this.ngUnsubscribe$.complete();
        }
    };
}

1	import { Subject } from 'rxjs';
2	import { OnDestroy } from '@angular/core';
3	import { Constructor } from './constructor';
4		21✔
5	export interface ThyUnsubscribe extends OnDestroy {
6	ngUnsubscribe$: Subject<void>;	×
7	}	×
8
9	/** Mixin to augment a directive with a `disableRipple` property. */
10	export function mixinUnsubscribe<T extends Constructor<{}>>(base: T): Constructor<ThyUnsubscribe> & T {	×
11	return class Mixin extends base {	×
12	ngUnsubscribe$ = new Subject<void>();	×
13
14	constructor(...args: any[]) {
15	super(...args);	×
16	}	×
17
18	ngUnsubscribeReinitialize() {
19	this.ngUnsubscribe$.next();
20	this.ngUnsubscribe$.complete();
21	this.ngUnsubscribe$ = new Subject();
22	}
23
24	ngOnDestroy() {
25	this.ngUnsubscribe$.next();
26	this.ngUnsubscribe$.complete();
27	}
28	};
29	}

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