Estoy trabajando con ngx socket io, cada vez que mi socket se conecte al servidor, reviso algunos datos que tengo en LocalStorage y los envío para almacenarlos en mi Base de datos principal.

Estoy usando namespace de socket io porque quiero mantener mi logica separada, así que hago lo siguiente.

Creo un servicio por cada namespace que voy a manejar

Dejare el link del repo por si necesitan mas detalles
https://dev.azure.com/raulandrade0511/_git/Testing%20Socket

    import { Socket } from 'ngx-socket-io';
    import { Injectable } from '@angular/core';
    
    //Services
    import { EmployeeService } from '../services/employee.service';
    import { OfflineService } from '../services/offline.service';
    
    //Interfaces
    import { HttpResponse } from '../interfaces/http-response.interface';
    
    @Injectable({ providedIn: 'root' })
    export class TestSocketOne extends Socket {  //Heredo de Socket para cada clase que use un namespace
      token: string;
    
      constructor(
        private employeeService: EmployeeService,
        private offlineService: OfflineService
      ) {
        super({ url: 'http://localhost:4000/testSocketOne', options: {} }); //Le indico la url con el manespace a connectarse
    
        this.initSocket();
      }
    
      async initSocket() {
        this.employeeService.token.subscribe((res) => { // estoý usando un middleware paraprotejer mi conexión
          this.token = res; //Obtengo mi token del local Storage
          this.ioSocket['auth'] = { token: this.token }; // Se lo asigno a mi Socket
          this.connect(); // Ejecuto la conexion
          this.onConnection(); //Metodo que detecta cada vez que se conecta al Socket
          this.receivedData();
        });
      }
    
      onConnection() {
        console.log('This method must be called once');
        this.fromEvent('connect').subscribe((message) => {
          console.log('This event must be called once by connection');
          this.sendData(); // Cada vez que se conecta al socket envío algunos datos de mi local Storage
        });
      }
    
      async sendData() {
        const data = await this.offlineService.storedData();
        if (data != null) {
          this.emit('sending-data', data); //Envío los datos en un evento de Socket
          console.log('mandando dato al socket'); // Está linea siempre se imprime 2 veces
        }
      }
    
      async receivedData() { //Al recibir los datos en el back, respondo con otro evento al front
        this.fromEvent<HttpResponse>('received-data').subscribe(async (res) => { // este es el evento que confirma el envío de datos
          const { message } = res.data;
          console.log('respuesta del back es ', message);
         /**
          * Aqui limpiaria mi local storage para no doplicar
          * registros en mi base de datos
          * pero al envíar 2 veces los datos antes de poder recibir una respuesta
          * estoy duplicando mis registros en la base datos,
          * y al intentar registrar la segunda vez, obtengo un error con valores unique
          */
        });
      }
    }