如何创建验证后返回可观察值的函数？

import { Observable } from 'rxjs';

function validateAndReturnObservable(input) {
  // 执行验证逻辑
  if (input === 'valid') {
    // 创建可观察值
    const observable = new Observable((observer) => {
      observer.next('Validation successful');
      observer.complete();
    });

    // 返回可观察值
    return observable;
  } else {
    // 创建可观察值
    const observable = new Observable((observer) => {
      observer.error('Validation failed');
    });

    // 返回可观察值
    return observable;
  }
}

// 调用函数并订阅可观察值
validateAndReturnObservable('valid').subscribe(
  (result) => {
    console.log(result);
  },
  (error) => {
    console.error(error);
  }
);