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): drop useless type assertion on server

Browse Source 
on every type assertion for `Observable<any>` that is not needed anymore.
This commit is contained in:
Micael Levi (lab)
2021-12-23 21:03:37 -04:00
parent cbec376216
commit f1b9b636a5
6 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -184,7 +184,7 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
const response$ = this.transformToObservable(
await handler(packet.data, kafkaContext),
) as Observable<any>;
);
response$ && this.send(response$, publish);
}

5
packages/microservices/server/server-mqtt.ts
View File

@@ -123,7 +123,7 @@ export class ServerMqtt extends Server implements CustomTransportStrategy {
}
const response$ = this.transformToObservable(
await handler(packet.data, mqttContext),
) as Observable<any>;
);
response$ && this.send(response$, publish);
}
@@ -191,7 +191,8 @@ export class ServerMqtt extends Server implements CustomTransportStrategy {
for (const [key, value] of this.messageHandlers) {
if (
!key.includes(MQTT_WILDCARD_SINGLE) && !key.includes(MQTT_WILDCARD_ALL)
!key.includes(MQTT_WILDCARD_SINGLE) &&
!key.includes(MQTT_WILDCARD_ALL)
) {
continue;
}

2
packages/microservices/server/server-nats.ts
View File

@@ -109,7 +109,7 @@ export class ServerNats extends Server implements CustomTransportStrategy {
}
const response$ = this.transformToObservable(
await handler(message.data, natsCtx),
) as Observable<any>;
);
response$ && this.send(response$, publish);
}

2
packages/microservices/server/server-redis.ts
View File

@@ -121,7 +121,7 @@ export class ServerRedis extends Server implements CustomTransportStrategy {
}
const response$ = this.transformToObservable(
await handler(packet.data, redisCtx),
) as Observable<any>;
);
response$ && this.send(response$, publish);
}

2
packages/microservices/server/server-rmq.ts
View File

@@ -157,7 +157,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
}
const response$ = this.transformToObservable(
await handler(packet.data, rmqContext),
) as Observable<any>;
);
const publish = <T>(data: T) =>
this.sendMessage(data, properties.replyTo, properties.correlationId);

2
packages/microservices/server/server-tcp.ts
View File

@@ -90,7 +90,7 @@ export class ServerTCP extends Server implements CustomTransportStrategy {
}
const response$ = this.transformToObservable(
await handler(packet.data, tcpContext),
) as Observable<any>;
);
response$ &&
this.send(response$, data => {