如何创建RxJS可观察对象，使其在回调函数完成时返回值

const observable = Observable.create(observer => {
  // 在这里执行异步操作或其他逻辑
  // 当操作完成时，调用observer.next()发送数据
  // 当出现错误时，调用observer.error()发送错误
  // 当操作完成且没有更多数据时，调用observer.complete()结束
});

observer.next(value);

observer.error(error);

observer.complete();

const { Observable } = require('rxjs');

const observable = Observable.create(observer => {
  // 模拟异步操作
  setTimeout(() => {
    const data = 'Hello, world!';
    observer.next(data); // 发送数据
    observer.complete(); // 结束数据流
  }, 1000);
});

const subscription = observable.subscribe(
  data => {
    console.log(data); // 处理接收到的数据
  },
  error => {
    console.error(error); // 处理错误
  },
  () => {
    console.log('Complete'); // 数据流结束
  }
);