54 lines
1.0 KiB
TypeScript
54 lines
1.0 KiB
TypeScript
|
import { Subject, PartialObserver } from 'rxjs';
|
||
|
|
|
||
|
|
export class Emitter {
|
||
|
|
private subjects: Map<string, Subject<any>>;
|
||
|
|
|
||
|
|
public constructor() {
|
||
|
|
this.subjects = new Map();
|
||
|
|
}
|
||
|
|
|
||
|
|
private static createName(name: string): string {
|
||
|
|
return '$' + name;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* emit
|
||
|
|
*/
|
||
|
|
public emit(name: string, data?: any) {
|
||
|
|
const fnName = Emitter.createName(name);
|
||
|
|
|
||
|
|
if (!this.subjects.has(fnName)) {
|
||
|
|
this.subjects.set(fnName, new Subject());
|
||
|
|
}
|
||
|
|
|
||
|
|
this.subjects.get(fnName).next(data);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* listen
|
||
|
|
*/
|
||
|
|
public listen(name: string, handler: (data?: any) => void) {
|
||
|
|
const fnName = Emitter.createName(name);
|
||
|
|
|
||
|
|
if (!this.subjects.has(fnName)) {
|
||
|
|
this.subjects.set(fnName, new Subject());
|
||
|
|
}
|
||
|
|
|
||
|
|
return this.subjects.get(fnName).subscribe(handler);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* dispose
|
||
|
|
*/
|
||
|
|
public dispose() {
|
||
|
|
const _subjects = this.subjects;
|
||
|
|
_subjects.forEach((value: Subject<any>, key: string) => {
|
||
|
|
if (_subjects.has(key)) {
|
||
|
|
_subjects.get(key).unsubscribe();
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
this.subjects = new Map();
|
||
|
|
}
|
||
|
|
}
|