fix(WebWorker): Make MessageBus EventEmitter synchronous

jteplitz · vsavkin · commit 69c16949001e · 2016-03-01T23:23:17.000Z
diff --git a/modules/angular2/src/web_workers/shared/post_message_bus.ts b/modules/angular2/src/web_workers/shared/post_message_bus.ts
@@ -31,7 +31,7 @@ export class PostMessageBusSink implements MessageBusSink {
       throw new BaseException(`${channel} has already been initialized`);
     }
 
-    var emitter = new EventEmitter();
+    var emitter = new EventEmitter(false);
     var channelInfo = new _Channel(emitter, runInZone);
     this._channels[channel] = channelInfo;
     emitter.subscribe((data: Object) => {
@@ -82,7 +82,7 @@ export class PostMessageBusSource implements MessageBusSource {
       throw new BaseException(`${channel} has already been initialized`);
     }
 
-    var emitter = new EventEmitter();
+    var emitter = new EventEmitter(false);
     var channelInfo = new _Channel(emitter, runInZone);
     this._channels[channel] = channelInfo;
   }

Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ export class PostMessageBusSink implements MessageBusSink {`
`31`	`31`	throw new BaseException(`${channel} has already been initialized`);
`32`	`32`	`}`
`33`	`33`
`34`		`- var emitter = new EventEmitter();`
	`34`	`+ var emitter = new EventEmitter(false);`
`35`	`35`	`var channelInfo = new _Channel(emitter, runInZone);`
`36`	`36`	`this._channels[channel] = channelInfo;`
`37`	`37`	`emitter.subscribe((data: Object) => {`
`@@ -82,7 +82,7 @@ export class PostMessageBusSource implements MessageBusSource {`
`82`	`82`	throw new BaseException(`${channel} has already been initialized`);
`83`	`83`	`}`
`84`	`84`
`85`		`- var emitter = new EventEmitter();`
	`85`	`+ var emitter = new EventEmitter(false);`
`86`	`86`	`var channelInfo = new _Channel(emitter, runInZone);`
`87`	`87`	`this._channels[channel] = channelInfo;`
`88`	`88`	`}`