#12 fix Emitter类移除监听时是否有错

This commit is contained in:
yhh
2020-07-15 10:53:30 +08:00
parent 983c8fbc99
commit 7dffb4d94a
10 changed files with 48 additions and 8 deletions
+1 -1
View File
@@ -8,7 +8,7 @@ declare interface Array<T> {
findAll(predicate: Function): Array<T>; findAll(predicate: Function): Array<T>;
contains(value: any): boolean; contains(value: any): boolean;
removeAll(predicate: Function): void; removeAll(predicate: Function): void;
remove(element: any): boolean; remove(element: T): boolean;
removeAt(index: any): void; removeAt(index: any): void;
removeRange(index: any, count: any): void; removeRange(index: any, count: any): void;
select(selector: Function): Array<T>; select(selector: Function): Array<T>;
+3 -1
View File
@@ -4883,7 +4883,9 @@ var Emitter = (function () {
list.push(new FuncPack(handler, context)); list.push(new FuncPack(handler, context));
}; };
Emitter.prototype.removeObserver = function (eventType, handler) { Emitter.prototype.removeObserver = function (eventType, handler) {
this._messageTable.get(eventType).remove(handler); var messageData = this._messageTable.get(eventType);
var index = messageData.findIndex(function (data) { return data.func == handler; });
messageData.removeAt(index);
}; };
Emitter.prototype.emit = function (eventType, data) { Emitter.prototype.emit = function (eventType, data) {
var list = this._messageTable.get(eventType); var list = this._messageTable.get(eventType);
File diff suppressed because one or more lines are too long
+7
View File
@@ -45,6 +45,13 @@ class MainScene extends Scene {
return new MainScene(); return new MainScene();
})); }));
}, this); }, this);
Main.emitter.addObserver(CoreEmitterType.Update, this.handleFuncTest, this);
}
/** 测试Emitter */
private handleFuncTest(){
Main.emitter.removeObserver(CoreEmitterType.Update, this.handleFuncTest);
} }
public breadthfirstTest() { public breadthfirstTest() {
+3
View File
@@ -0,0 +1,3 @@
{
"typescript.tsdk": "./node_modules/typescript/lib"
}
+1 -1
View File
@@ -8,7 +8,7 @@ declare interface Array<T> {
findAll(predicate: Function): Array<T>; findAll(predicate: Function): Array<T>;
contains(value: any): boolean; contains(value: any): boolean;
removeAll(predicate: Function): void; removeAll(predicate: Function): void;
remove(element: any): boolean; remove(element: T): boolean;
removeAt(index: any): void; removeAt(index: any): void;
removeRange(index: any, count: any): void; removeRange(index: any, count: any): void;
select(selector: Function): Array<T>; select(selector: Function): Array<T>;
+3 -1
View File
@@ -4883,7 +4883,9 @@ var Emitter = (function () {
list.push(new FuncPack(handler, context)); list.push(new FuncPack(handler, context));
}; };
Emitter.prototype.removeObserver = function (eventType, handler) { Emitter.prototype.removeObserver = function (eventType, handler) {
this._messageTable.get(eventType).remove(handler); var messageData = this._messageTable.get(eventType);
var index = messageData.findIndex(function (data) { return data.func == handler; });
messageData.removeAt(index);
}; };
Emitter.prototype.emit = function (eventType, data) { Emitter.prototype.emit = function (eventType, data) {
var list = this._messageTable.get(eventType); var list = this._messageTable.get(eventType);
+1 -1
View File
File diff suppressed because one or more lines are too long
+1 -1
View File
@@ -48,7 +48,7 @@ declare interface Array<T> {
* *
* @param element * @param element
*/ */
remove(element): boolean; remove(element: T): boolean;
/** /**
* *
* @param index * @param index
+27 -1
View File
@@ -1,3 +1,6 @@
/**
*
*/
class Emitter<T> { class Emitter<T> {
private _messageTable: Map<T, FuncPack[]>; private _messageTable: Map<T, FuncPack[]>;
@@ -5,6 +8,12 @@ class Emitter<T> {
this._messageTable = new Map<T, FuncPack[]>(); this._messageTable = new Map<T, FuncPack[]>();
} }
/**
*
* @param eventType
* @param handler
* @param context
*/
public addObserver(eventType: T, handler: Function, context: any){ public addObserver(eventType: T, handler: Function, context: any){
let list: FuncPack[] = this._messageTable.get(eventType); let list: FuncPack[] = this._messageTable.get(eventType);
if (!list){ if (!list){
@@ -17,10 +26,22 @@ class Emitter<T> {
list.push(new FuncPack(handler, context)); list.push(new FuncPack(handler, context));
} }
/**
*
* @param eventType
* @param handler
*/
public removeObserver(eventType: T, handler: Function){ public removeObserver(eventType: T, handler: Function){
this._messageTable.get(eventType).remove(handler); let messageData = this._messageTable.get(eventType);
let index = messageData.findIndex(data => data.func == handler);
messageData.removeAt(index);
} }
/**
*
* @param eventType
* @param data
*/
public emit(eventType: T, data?: any){ public emit(eventType: T, data?: any){
let list: FuncPack[] = this._messageTable.get(eventType); let list: FuncPack[] = this._messageTable.get(eventType);
if (list){ if (list){
@@ -30,8 +51,13 @@ class Emitter<T> {
} }
} }
/**
*
*/
class FuncPack { class FuncPack {
/** 函数 */
public func: Function; public func: Function;
/** 上下文 */
public context: any; public context: any;
constructor(func: Function, context: any){ constructor(func: Function, context: any){