数据流与Promises：使用serialport在Node.js中的应用

Question

数据流与Promises：使用serialport在Node.js中的应用

4

我正在开发一个使用串口与微控制器通信的nodejs项目。我可以使用serialport使一切正常工作，但我在确定处理接收到数据的最佳方法方面遇到了困难。

下面是我正在测试的基本程序：

const serialPort = require('serialport');
const delimiter = require('@serialport/parser-delimiter')

const readline = require('readline');
const EventEmitter = require('events');

const rl = readline.createInterface({
  input: process.stdin, 
  output: process.stdout
});

rl.setPrompt('> ');
rl.prompt();

const uart = new serialPort('path-to-port', {
  baudRate: 9600
});

const parser = uart.pipe(new delimiter({ delimiter: '\n'}));

const event = new EventEmitter();

parser.on('data', (data) => {
  event.emit('dataReady', data);
});

rl.on('line', (input) => {
  if(input === 'close'){
    console.log('Bye');
    process.exit();
  }

  uart.write(input + '\n', (err) => {
    if (err) {
      console.log('uart write error');
    }
  });

  console.log('Waiting on data...');
  readAsync().then((data) => {
    console.log(' ->', data.toString());
    rl.prompt();
  });


});

const readAsync = () => {
  const promise = new Promise((resolve, reject) => {
    event.once('dataReady', (data) => {
      resolve(data);
    });
  });

  return promise;
}

我希望返回一个承诺，一旦收到数据就会被实现。目前我正在发出事件并使用侦听器来实现承诺。这是最好的方法还是有更好的选择？

更新

我计划导出一个写入串行端口的函数，一旦收到数据就会实现一个承诺。

例如：

module.exports.write = (cmd) => {
  uart.write(input + '\n', (err) => {
    if (err) {
      console.log('uart write error');
    }
  });
  return readAsync();
}

- Dillon Wiggins

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Jclangst · Accepted Answer

对于流式传输任意数量的数据（即，parser对象可能有很多data事件），您可能不想使用promise。一旦promise被解决，它就会永久解决（即，您只能将数据放入其中一次--这看起来像是您已经设置了readAsync的方式）。您可能希望尝试称为Observable的东西。您可以将可观察对象连接到相关的流中，并将其排队以进行后续转换或使用（您可以将其视为可以接受多个数据项的promise）。这里有一个好的SO答案，解释了流（您当前正在使用的内容）和可观察对象如何相互操作以获得更多的编程灵活性。

不幸的是，Node.js没有内置的Observable实用程序，但有一个经典而经过验证的解决方案，RxJS。