mkarkowski/nope
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

Make shure we are waiting for subscriptions.

Browse Source
This commit is contained in:
Martin Karkowski 2021-03-19 13:20:35 +01:00
parent 75f3c58543
commit 8c623e13ef
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
lib/dispatcher/nopeDispatcher.ts
View File

@ -832,7 +832,7 @@ export class nopeDispatcher implements INopeDispatcher {
// Subscribe to the availableServices of Remotes.
// If there is a new Service => udpate the External Services
this.communicator.onNewServicesAvailable((data) => {
await this.communicator.onNewServicesAvailable((data) => {
try {
if (data.dispatcher !== _this.id) {
_this._mappingOfRemoteDispatchersAndServices.set(
@ -853,7 +853,7 @@ export class nopeDispatcher implements INopeDispatcher {
});
// Subscribe to new available Topics.
this.communicator.onNewObservablesAvailable((data) => {
await this.communicator.onNewObservablesAvailable((data) => {
try {
if (data.dispatcher !== _this.id) {
_this._mappingOfRemoteDispatchersAndPropsOrEvents.set(
@ -873,7 +873,7 @@ export class nopeDispatcher implements INopeDispatcher {
} catch (e) {}
});
this.communicator.onNewInstanceGeneratorsAvailable((data) => {
await this.communicator.onNewInstanceGeneratorsAvailable((data) => {
try {
_this._mappingOfRemoteDispatchersAndGenerators.set(
data.dispatcher,
@ -891,14 +891,14 @@ export class nopeDispatcher implements INopeDispatcher {
} catch (e) {}
});
this.communicator.onStatusUpdate((info) => {
await this.communicator.onStatusUpdate((info) => {
_this._externalDispatchers.set(info.id, info);
_this.externalDispatchers.setContent(
Array.from(_this._externalDispatchers.values())
);
});
this.communicator.onBonjour((info) => {
await this.communicator.onBonjour((info) => {
_this._externalDispatchers.set(info.id, info);
_this.externalDispatchers.setContent(
Array.from(_this._externalDispatchers.values())
@ -919,12 +919,12 @@ export class nopeDispatcher implements INopeDispatcher {
}
});
this.communicator.onAurevoir((dispatcher: string) =>
await this.communicator.onAurevoir((dispatcher: string) =>
_this._removeDispatcher(dispatcher)
);
// Listen to newly created instances.
this.communicator.onNewInstancesAvailable((message) => {
await this.communicator.onNewInstancesAvailable((message) => {
// Store the instances:
_this._mappingOfRemoteDispatchersAndInstances.set(
message.dispatcher,
@ -944,7 +944,7 @@ export class nopeDispatcher implements INopeDispatcher {
}
});
this.communicator.onTaskCancelation((event) => {
await this.communicator.onTaskCancelation((event) => {
if (event.dispatcher !== _this.id) {
_this.canceledTask.setContent(event);
}
@ -953,7 +953,7 @@ export class nopeDispatcher implements INopeDispatcher {
if (this._logger) {
this._logger.info("initialized");
}
this.communicator.emitBonjour(this._genAliveMessage());
await this.communicator.emitBonjour(this._genAliveMessage());
this.ready.setContent(true);
}