amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(microservices): remove 3 unnecessary await

Browse Source
This commit is contained in:
Guilherme Ruiz
2021-12-17 10:31:29 +11:00
parent 01daeb441f
commit 58950a0dee
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/microservices/server/server-kafka.ts
View File

@@ -141,7 +141,7 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
correlationId: string,
): (data: any) => Promise<RecordMetadata[]> {
return async (data: any) =>
await this.sendMessage(data, replyTopic, replyPartition, correlationId);
this.sendMessage(data, replyTopic, replyPartition, correlationId);
}
public async handleMessage(payload: EachMessagePayload) {
@@ -207,7 +207,7 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
},
this.options.send || {},
);
return await this.producer.send(replyMessage);
return this.producer.send(replyMessage);
}
public assignIsDisposedHeader(