如何将 Dart IO 进程设置为使用现有流作为其标准

Question

我正在使用Process.start创建一个进程，并且有点卡在stdin getter上。理想情况下，我在其他地方设置了一个 StreamController，我想将其字符串流传递到 stdin。但是没有太多复杂的示例与Process.stdin交互，所以我不确定除了写到stdin之外如何做任何事情。

所以我有这样的东西，我可以将字符串消息添加到：

  StreamController<String> processInput = new StreamController<String>.broadcast();

我想做这样的事情：

  Process.start(executable, args, workingDirectory: dir.path, runInShell: true).then((Process process) {
process.stdout
  .transform(UTF8.decoder)
  .listen((data) {
    s.add('[[CONSOLE_OUTPUT]]' + data);
  });
process.stdin.addStream(input.stream);
});

我意识到addStream()想要Stream<List<int>>，尽管我不确定为什么会这样。

Answer 1

stdin对象是一个IOSink，所以它有一个字符串的write方法。这将默认为 UTF-8 编码字符串。所以，而不是

process.stdin.addStream(input.stream)

你可以做

IOSink stdin = process.stdin;
input.stream.listen(stdin.write, onDone: stdin.close);

您可能需要一些错误处理，可能在写入之间刷新 stdin，所以也许：

input.stream.listen(
    (String data) {
      stdin.write(data);
      stdin.flush();
    }, 
    onError: myErrorHandler,
    onDone: stdin.close);

或者，您可以手动执行 UTF-8 编码，以获取addStream期望的整数列表流：

process.stdin.addStream(input.stream.transform(UTF8.encoder))

stdin期望List<int>的原因是，进程通信的核心只是字节。发送文本需要发送方和接收方预先商定编码，以便他们可以以相同的方式解释字节。

Answer 2

这可能有效

process.stdin.addStream(UTF8.encoder.bind(input.stream));