Forwarding the status and events.

This commit is contained in:
Martin Karkowski 2021-03-01 14:32:43 +01:00
parent b43733d065
commit b64da70b6c

View File

@ -2,7 +2,7 @@
* @author Martin Karkowski
* @email m.karkowski@zema.de
* @create date 2020-11-06 08:52:36
* @modify date 2021-02-05 10:15:20
* @modify date 2021-03-01 14:24:13
* @desc [description]
*/
@ -46,7 +46,14 @@ const METHOD_MAPPING: {
onRpcRequest: "emitRpcRequest",
onRpcResponse: "emitRpcResponse",
onTaskCancelation: "emitTaskCancelation",
onStatusUpdate: "emitStatusUpdate"
onStatusUpdate: "emitStatusUpdate",
emitAurevoir: "emitAurevoir",
emitBonjour: "emitBonjour",
emitEvent: "emitEvent",
emitNewInstanceGeneratorsAvailable: "emitNewInstanceGeneratorsAvailable",
emitNewObersvablesAvailable: "emitNewObersvablesAvailable",
emitNewInstancesAvailable: "emitNewInstancesAvailable",
emitNewServicesAvailable: "emitNewServicesAvailable",
};
const STORING: Array<keyof ICommunicationInterface> = [
@ -281,6 +288,7 @@ export class Bridge implements ICommunicationInterface {
}
protected _wrappedMethods = new Map<(data) => any, (data) => any>();
protected _wrapMethod(
name: string,
cb: (data) => any,
@ -303,6 +311,7 @@ export class Bridge implements ICommunicationInterface {
this._wrappedMethods.set(cb, _wrapped);
return _wrapped;
}
protected _wrapMethodWithoutName(
cb: (data) => any,
layer: ICommunicationInterface,