feature() add external context, microservices event patterns

This commit is contained in:
Kamil Myśliwiec
2019-01-04 16:59:11 +01:00
parent f0e9b40e2c
commit 4f767080bf
85 changed files with 5029 additions and 214 deletions

View File

@@ -52,7 +52,10 @@ export class ClientTCP extends ClientProxy {
share(),
);
this.socket.connect(this.port, this.host);
this.socket.connect(
this.port,
this.host,
);
this.connection = source$.toPromise();
return this.connection;
}
@@ -117,4 +120,9 @@ export class ClientTCP extends ClientProxy {
callback({ err });
}
}
protected async dispatchEvent(packet: ReadPacket): Promise<any> {
const pattern = this.normalizePattern(packet.pattern);
return this.socket.sendMessage(pattern);
}
}