如何将回调转换为Rx.Observable？

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

// 定义一个回调函数
function callback(data, callback) {
  // 处理回调数据
  console.log('Received data:', data);

  // 调用回调函数通知完成
  callback();
}

// 将回调转换为Observable
const observable = fromEventPattern(
  (handler) => {
    // 在这里订阅回调函数
    callback('Hello World', handler);
  },
  (handler) => {
    // 在这里取消订阅回调函数（可选）
    // 如果不需要取消订阅，可以省略这个参数
  }
);

// 订阅Observable
const subscription = observable.subscribe({
  next: (data) => {
    console.log('Received data from Observable:', data);
  },
  complete: () => {
    console.log('Observable completed');
  }
});

// 取消订阅（可选）
// subscription.unsubscribe();