javascript 具有自动阵列兼容性的同步RxJS

Posted 2021-05-03

const createExecutableObservable = (
  source$,
) => {
  Array
  .isArray(source$)
  && (
    source$ = from(source$)
  )

  source$
  .__proto__ = new ExecutableObservable()

  return source$
}