javascript 使用RxJS执行同步传感器

Posted 2021-05-03

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

const createExecutableObservable = require('./createExecutableObservable')

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

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