File tree Expand file tree Collapse file tree
packages/platform-ws/adapters
sample/03-microservices/src/math Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -55,7 +55,10 @@ export class WsAdapter extends AbstractWsAdapter {
5555 handlers : MessageMappingProperties [ ] ,
5656 transform : ( data : any ) => Observable < any > ,
5757 ) {
58- const close$ = fromEvent ( client , CLOSE_EVENT ) . pipe ( share ( ) , first ( ) ) ;
58+ const close$ = fromEvent ( client , CLOSE_EVENT ) . pipe (
59+ share ( ) ,
60+ first ( ) ,
61+ ) ;
5962 const source$ = fromEvent ( client , 'message' ) . pipe (
6063 mergeMap ( data =>
6164 this . bindMessageHandler ( data , handlers , transform ) . pipe (
@@ -97,4 +100,8 @@ export class WsAdapter extends AbstractWsAdapter {
97100 server . on ( ERROR_EVENT , ( err : any ) => this . logger . error ( err ) ) ;
98101 return server ;
99102 }
103+
104+ public bindClientDisconnect ( client : any , callback : Function ) {
105+ client . on ( CLOSE_EVENT , callback ) ;
106+ }
100107}
Original file line number Diff line number Diff line change @@ -3,6 +3,7 @@ import { Transport } from '@nestjs/common/enums/transport.enum';
33import { ClientsModule } from '@nestjs/microservices' ;
44import { MATH_SERVICE } from './math.constants' ;
55import { MathController } from './math.controller' ;
6+
67@Module ( {
78 imports : [
89 ClientsModule . register ( [ { name : MATH_SERVICE , transport : Transport . TCP } ] ) ,
You can’t perform that action at this time.
0 commit comments