javascript 具有发生器的同步RxJS执行

Posted 2021-05-03

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

const createExecutableObservable = require('./createExecutableObservable')

const createGenerator = function*() {
  yield 1
  yield 2
  yield 3
  yield 4
}

const value = (
  createExecutableObservable(
    from(createGenerator())
  )
  .pipe(
    map(String),
    toArray(),
  )
  .execute()
)

console.log(value)
// ['1', '2', '3', '4']