在Angular的单元测试中，可以使用TestBed来创建组件实例，并且可以模拟组件的依赖项。对于ngOnInit中的订阅，可以使用of和Subject来模拟一个可观察对象，并在测试中手动触发订阅。

下面是一个示例代码，演示如何进行单元测试一个包含ngOnInit订阅的组件：

import { ComponentFixture, TestBed } from '@angular/core/testing';
import { MyComponent } from './my.component';
import { of, Subject } from 'rxjs';

describe('MyComponent', () => {
  let component: MyComponent;
  let fixture: ComponentFixture;
  let myServiceMock: any;

  beforeEach(async () => {
    // 创建一个模拟的服务
    myServiceMock = {
      getData: jasmine.createSpy('getData').and.returnValue(of('mock data'))
    };

    await TestBed.configureTestingModule({
      declarations: [ MyComponent ],
      providers: [
        { provide: MyService, useValue: myServiceMock }
      ]
    })
    .compileComponents();
  });

  beforeEach(() => {
    fixture = TestBed.createComponent(MyComponent);
    component = fixture.componentInstance;
  });

  it('should subscribe to data on ngOnInit', () => {
    // 创建一个用于手动触发订阅的Subject
    const dataSubject = new Subject();

    // 将模拟的数据流设置为Subject
    myServiceMock.getData.and.returnValue(dataSubject.asObservable());

    // 手动触发组件的ngOnInit
    component.ngOnInit();

    // 断言订阅之前的状态
    expect(component.data).toBeUndefined();

    // 发出一个模拟的数据
    const testData = 'test data';
    dataSubject.next(testData);

    // 断言订阅之后的状态
    expect(component.data).toBe(testData);
  });
});

在上面的示例中，我们创建了一个模拟的服务myServiceMock，并使用jasmine.createSpy来创建一个模拟的getData方法。在beforeEach块中，我们将模拟的服务提供给组件的提供者。然后，在it块中，我们创建了一个Subject来模拟数据流，并将它设置为模拟服务的返回值。然后，我们手动调用了组件的ngOnInit方法，并断言订阅之前和之后的组件状态。

这样，我们就可以测试ngOnInit中的订阅逻辑，并确保它按预期工作。