File tree Expand file tree Collapse file tree
packages/microservices/client Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -15,14 +15,14 @@ import { IncomingResponseDeserializer } from '../deserializers/incoming-response
1515import { InvalidMessageException } from '../errors/invalid-message.exception' ;
1616import {
1717 ClientOptions ,
18+ KafkaOptions ,
1819 MqttOptions ,
1920 MsPattern ,
2021 NatsOptions ,
2122 PacketId ,
2223 ReadPacket ,
2324 RedisOptions ,
2425 RmqOptions ,
25- KafkaOptions ,
2626 TcpClientOptions ,
2727 WritePacket ,
2828} from '../interfaces' ;
@@ -85,7 +85,7 @@ export abstract class ClientProxy {
8585 return ( { err, response, isDisposed } : WritePacket ) => {
8686 if ( err ) {
8787 return observer . error ( err ) ;
88- } else if ( response && isDisposed ) {
88+ } else if ( response !== undefined && isDisposed ) {
8989 observer . next ( response ) ;
9090 return observer . complete ( ) ;
9191 } else if ( isDisposed ) {
You can’t perform that action at this time.
0 commit comments