如何在Jasmine中模拟rxjs webSocket？

const mockWebSocket = jasmine.createSpyObj('WebSocket', ['send', 'close']);

const mockWebSocketSubject = new Subject();
const mockWebSocketObservable = Observable.create(observer => {
  mockWebSocketSubject.subscribe(observer);
  return mockWebSocket;
});

it('should send message via WebSocket', () => {
  // 模拟WebSocket的行为
  mockWebSocketSubject.next('Hello, WebSocket!');

  // 验证逻辑
  expect(mockWebSocket.send).toHaveBeenCalledWith('Hello, WebSocket!');
});

it('should close WebSocket connection', () => {
  // 模拟WebSocket的行为
  mockWebSocketSubject.complete();

  // 验证逻辑
  expect(mockWebSocket.close).toHaveBeenCalled();
});

afterEach(() => {
  mockWebSocket.send.calls.reset();
  mockWebSocket.close.calls.reset();
  mockWebSocketSubject.complete();
});