创建订阅observable的泛型函数

import { Observable } from 'rxjs';

// 泛型函数，用于创建一个发出指定类型值的 Observable
function createObservable<T>(initialValue: T): Observable<T> {
  return new Observable(subscriber => {
    subscriber.next(initialValue);
    // 可以在这里添加更多的逻辑来发出更多的值
  });
}

// 使用泛型函数创建一个发出 number 类型的 Observable
const numberObservable = createObservable<number>(10);

numberObservable.subscribe({
  next(value) {
    console.log('Received number:', value);
  },
  error(err) {
    console.error('Error:', err);
  },
  complete() {
    console.log('Completed');
  }
});

// 使用泛型函数创建一个发出 string 类型的 Observable
const stringObservable = createObservable<string>('Hello, world!');

stringObservable.subscribe({
  next(value) {
    console.log('Received string:', value);
  },
  error(err) {
    console.error('Error:', err);
  },
  complete() {
    console.log('Completed');
  }
});

import { takeUntil } from 'rxjs/operators';
import { Subject } from 'rxjs';

const destroy$ = new Subject<void>();

constructor() {
  createObservable<number>(10).pipe(
    takeUntil(destroy$)
  ).subscribe({
    next(value) {
      console.log('Received number:', value);
    }
  });
}

ngOnDestroy() {
  destroy$.next();
  destroy$.complete();
}