如何在socket.emit中从angular添加回调(new ())

import { Component, OnInit } from '@angular/core';
import { Observable } from 'rxjs';
import { Socket } from 'socket.io-client';

@Component({
  selector: 'app-example-component',
  templateUrl: './example-component.component.html',
  styleUrls: ['./example-component.component.css']
})
export class ExampleComponent implements OnInit {
  private socket: Socket;

  constructor() {
    // 建立WebSocket连接
    this.socket = io('<your-server-url>');
  }

  ngOnInit() {
    // 监听服务器返回的回调数据
    this.listenForCallback().subscribe((data) => {
      // 在这里处理回调数据
      console.log(data);
    });
  }

  // 发送数据并添加回调
  sendDataWithCallback(data: any): Observable<any> {
    return new Observable((observer) => {
      this.socket.emit('event-name', data, (callbackData) => {
        observer.next(callbackData);
        observer.complete();
      });
    });
  }

  // 监听服务器返回的回调数据
  listenForCallback(): Observable<any> {
    return new Observable((observer) => {
      this.socket.on('callback-event-name', (callbackData) => {
        observer.next(callbackData);
      });
    });
  }
}