emitter 支持 context

This commit is contained in:
YHH
2020-07-12 23:41:10 +08:00
parent 14598f08c7
commit f0e04b6981
7 changed files with 51 additions and 17 deletions

View File

@@ -1044,10 +1044,15 @@ declare class DrawUtils {
declare class Emitter<T> {
private _messageTable;
constructor();
addObserver(eventType: T, handler: Function): void;
addObserver(eventType: T, handler: Function, context: any): void;
removeObserver(eventType: T, handler: Function): void;
emit(eventType: T, data?: any): void;
}
declare class FuncPack {
func: Function;
context: any;
constructor(func: Function, context: any);
}
declare class GlobalManager {
static globalManagers: GlobalManager[];
private _enabled;

View File

@@ -4880,7 +4880,7 @@ var Emitter = (function () {
function Emitter() {
this._messageTable = new Map();
}
Emitter.prototype.addObserver = function (eventType, handler) {
Emitter.prototype.addObserver = function (eventType, handler, context) {
var list = this._messageTable.get(eventType);
if (!list) {
list = [];
@@ -4888,7 +4888,7 @@ var Emitter = (function () {
}
if (list.contains(handler))
console.warn("您试图添加相同的观察者两次");
list.push(handler);
list.push(new FuncPack(handler, context));
};
Emitter.prototype.removeObserver = function (eventType, handler) {
this._messageTable.get(eventType).remove(handler);
@@ -4897,11 +4897,18 @@ var Emitter = (function () {
var list = this._messageTable.get(eventType);
if (list) {
for (var i = list.length - 1; i >= 0; i--)
list[i](data);
list[i].func.call(list[i].context, data);
}
};
return Emitter;
}());
var FuncPack = (function () {
function FuncPack(func, context) {
this.func = func;
this.context = context;
}
return FuncPack;
}());
var GlobalManager = (function () {
function GlobalManager() {
}

File diff suppressed because one or more lines are too long

View File

@@ -1,12 +1,12 @@
class Emitter<T> {
private _messageTable: Map<T, Function[]>;
private _messageTable: Map<T, FuncPack[]>;
constructor(){
this._messageTable = new Map<T, Function[]>();
this._messageTable = new Map<T, FuncPack[]>();
}
public addObserver(eventType: T, handler: Function){
let list: Function[] = this._messageTable.get(eventType);
public addObserver(eventType: T, handler: Function, context: any){
let list: FuncPack[] = this._messageTable.get(eventType);
if (!list){
list = [];
this._messageTable.set(eventType, list);
@@ -14,7 +14,7 @@ class Emitter<T> {
if (list.contains(handler))
console.warn("您试图添加相同的观察者两次");
list.push(handler);
list.push(new FuncPack(handler, context));
}
public removeObserver(eventType: T, handler: Function){
@@ -22,10 +22,20 @@ class Emitter<T> {
}
public emit(eventType: T, data?: any){
let list: Function[] = this._messageTable.get(eventType);
let list: FuncPack[] = this._messageTable.get(eventType);
if (list){
for (let i = list.length - 1; i >= 0; i --)
list[i](data);
list[i].func.call(list[i].context, data);
}
}
}
class FuncPack {
public func: Function;
public context: any;
constructor(func: Function, context: any){
this.func = func;
this.context = context;
}
}