Dart中的stdout.write（）顯然已從同步更改爲異步，但我該如何使用它？

Question

我在Dart的許多地方使用stdout.write（），以免去換行。它工作正常，但最近從同步更改爲異步。我已經在Win7-32​​和Win8-64上升級到Dart 28355。

下面介紹的變化：

「什麼樣的變化 寫入輸出和錯誤曾經被封鎖，在所有平臺上作爲清除的一部分，這是目前異步/非阻塞任何其他？行旅中鏢：IO 如何更新我的代碼 大多數代碼應該只是像以前那樣，除極少數情況下調用「退出」的時候：」

的，我想達到什麼樣的一個小例子如下：

import 'dart:io'; 

main() { 
    String sCorrectYn; 
    while (sCorrectYn != "y") { 
    String sName = fInputString("Enter Name : ");  
    sCorrectYn = fInputString("Details Correct? (y/n) : "); 
    } 
} 

String fInputString(String sPrompt) { 
    stdout.write("\n$sPrompt"); 
    return stdin.readLineSync().toLowerCase(); 
} 

012上運行的win8以上時

端子輸出如下：

c:\Users\boh\dart-dev1\testpg001>dart testinput001.dart 

Enter Name : abcd 
n 
xxxx 
n 
zzzz 
y 

Details Correct? (y/n) : 
Enter Name : 
Details Correct? (y/n) : 
Enter Name : 
Details Correct? (y/n) : 
c:\Users\boh\dart-dev1\testpg001> 

什麼與上述發生的是，所有的終端輸出的出現後我最後輸入「Y」，這將終止該程序並刷新輸出緩衝區（它出現）。第一個終端輸出「輸入名稱：」是它應該發生的唯一輸出。

看來stdout沒有「flush」方法。

我沒有用未來的stdout做實驗，但是我無法讓它正常工作。

我怎樣才能以需要的方式工作？

以下也如使用stdout.write（）所需的不工作：

import 'dart:io'; 

main() { 
    String sInput; 
    stdout.write("\nEntry 1 : "); 
    sInput = stdin.readLineSync(); 
    print("Date Entered (1) was : $sInput"); 
    stdout.write("\nEntry 2 : "); 
    sInput = stdin.readLineSync(); 
    print("Date Entered (2) was : $sInput"); 
    stdout.write("\nEntry 3 : "); 
    sInput = stdin.readLineSync(); 
    print("Date Entered (3) was : $sInput"); 
    stdout.write("\nEntry 4 : "); 
    sInput = stdin.readLineSync(); 
    print("Date Entered (4) was : $sInput"); 
    stdout.write("\nEntry 5 : "); 
    sInput = stdin.readLineSync(); 
    print("Date Entered (5) was : $sInput"); 
} 

終端顯示用於上述顯示第一行「條目1：」是當使用stdout.write（當僅需要顯示線）：

c:\Users\boh\dart-dev1\testpg001>dart testinput003.dart 

Entry 1 : aaa 
Date Entered (1) was : aaa 
bbb 
Date Entered (2) was : bbb 
ccc 
Date Entered (3) was : ccc 
ddd 
Date Entered (4) was : ddd 
eee 
Date Entered (5) was : eee 

Entry 2 : 
Entry 3 : 
Entry 4 : 
Entry 5 : 
c:\Users\boh\dart-dev1\testpg001> 

Answer 1

要「刷」一IOSink可以通過使用StreamController創建一個新的Stream可以等待實現的能力。我已經使用writeAndFlush輔助方法重寫了上面的示例。

import 'dart:async'; 
import 'dart:convert'; 
import 'dart:io'; 

main() { 
    void loop() { 
    fInputString("Enter Name : ") 
     .then((_) => fInputString("Details Correct? (y/n) : ")) 
     .then((sCorrectYn) { 
     if (sCorrectYn != "y") loop(); 
     }); 
    } 
    loop(); 
} 

Future<String> fInputString(String sPrompt) { 
    return writeAndFlush(stdout, "\n$sPrompt") 
    .then((_) { 
     return stdin.readLineSync().toLowerCase(); 
    }); 
} 

Future writeAndFlush(IOSink sink, object) { 
    return sink.addStream(
    (new StreamController() 
     ..add(UTF8.encode(object.toString())) 
     ..close()) 
     .stream); 
} 

添加flush到IOSink，那正是這一點，是我們應該考慮的選擇。

請注意，這實際上不是在IO級別上「刷新」，而是等待Stream讀取結束，即等待Stream可能被操作系統暫停和恢復。