如何在Jasmine中测试RxJs WebSocket

import { WebSocketSubject } from 'rxjs/webSocket';
import { of } from 'rxjs';
import { take } from 'rxjs/operators';

describe('WebSocket', () => {
  let webSocket: WebSocketSubject<any>;

  beforeEach(() => {
    // 在每个测试用例之前创建一个新的WebSocketSubject实例
    webSocket = new WebSocketSubject('ws://localhost:8080');
  });

  afterEach(() => {
    // 在每个测试用例之后关闭WebSocket连接
    webSocket.complete();
  });

  it('should receive messages', (done) => {
    const expectedMessage = 'Hello, WebSocket!';

    // 使用RxJs的take操作符来限制只接收一个消息
    webSocket.pipe(take(1)).subscribe((message) => {
      expect(message).toEqual(expectedMessage);
      done();
    });

    // 模拟发送消息到WebSocket服务器
    webSocket.next(expectedMessage);
  });

  it('should handle errors', (done) => {
    const expectedError = 'WebSocket error';

    // 使用RxJs的take操作符来限制只接收一个错误
    webSocket.pipe(take(1)).subscribe({
      error: (error) => {
        expect(error).toEqual(expectedError);
        done();
      },
    });

    // 模拟WebSocket连接错误
    webSocket.error(expectedError);
  });
});