javascript - RxJS 和 Busboy

Question

有一个busboy library 。通过一些 Promise 库，我可以使用以下代码将整个表单数据收集到一个对象中:

var p = new Promise((resolve) => {
  let res = {}
  busboy.on('file', (fieldname, file, filename, encoding, mimetype)=> {
    let name = uuid.v1()
    let extension = path.extname(filename)
    let saveTo = path.resolve(mediaPath, `${name}${extension}`)
    file.pipe(fs.createWriteStream(saveTo))
    res = _.extend(res, {
      [fieldname]: { filename }
    })
  })
  busboy.on('field', (key, value, keyTruncated, valueTruncated) => {
    res = _.extend({[key]: value})
  })
  busboy.on('finish', () => resolve(res))
})
p.then((data) => ...

它可以工作，但看起来有点像意大利面条。有没有办法用 RxJS 改进这个示例？

Answer 1

我可以考虑一些使用 Rxjs 的方法，但我不确定这是否意味着需要更少的代码。

你可以:- 包装 Busboy 库事件的方式与使用 Rx.Observable.fromEvent 包装 DOM 事件的方式相同。

然后做这样的事情:

var fileEvent$ = Rx.Observable.fromBusyBoyEvent('file');
var fieldEvent$ = Rx.Observable.fromBusyBoyEvent('field');
var finishEvent$ = Rx.Observable.fromBusyBoyEvent('finish');
var processFileEvent = function ( res, fieldname, file, filename, encoding, mimetype ) {
  /*code here*/
  return {res : /* something*/, done : false}
};
var processFieldEvent = function ( res, key, value, keyTruncated, valueTruncated ) {/*code here*/
  return {res : /* something*/, done : false}
};
var processFinishEvent = function ( res ) {return {res : res, done : true}};

var passReducer = function ( reduce_fn ) {
  return function () {
    return {args : arguments, reduce_fn : reduce_fn}
  }
};

var res$ = Rx.Observable
    .merge(
    fileEvent$.map(passReducer(processFileEvent)),
    fieldEvent$.map(passReducer(processFieldEvent)),
    finishEvent$.map(passReducer(processFinishEvent)))
    .scan(function ( acc, command ) {
            return command.reduce_fn.apply(null, command.args);
          }, {})
    .filter(function ( acc ) {return acc.done});