javascript 使用RxJS的同步传感器执行错误

Posted 2021-05-03

const { delay, map, toArray } = require('rxjs/operators')
const { from } = require('rxjs')

const createExecutableObservable = require('./createExecutableObservable')

const asyncValue = (
  createExecutableObservable(
    from([1, 2, 3, 4])
  )
  .pipe(
    map(String),
    delay(1000),
    toArray(),
  )
  .execute()
)

console.log(asyncValue)
// undefined

// 1 second later
// Error: Cannot return multiple values in `createExecutableObservable`. Make sure your pipeline returns only a single value and doesn't use asynchronous operators.