ngx-socket-io
если используется, то в нем уже есть готовый метод для получения обсервабла, все ж в доке написано return () => this.socket.off('server-response', listener);
serverResponse = new Observable(observer => {
const listener = data => ovserver.next(data);
this.socket.on('server-response', listener );
return () => this.socket.off('server-response', listener);
}).pipe(share());
первое что нашлось
Может все уже решали и решили