飛鏢中的Channel原始？

Question

Dart中是否有一個channel原始圖像，例如Go？我發現最接近的是StreamIterator。

用例將允許用戶逐一異步處理值。另外，如果沒有價值，它應該等待。

Answer 1

你可以用流做到這一點

import 'dart:async' show Stream, StreamController; 

main() { 
    StreamController<int> sc = new StreamController<int>(); 

    sc.stream.listen((e) => print(e)); 

    for(int i = 0; i < 10; i++) { 
    sc.add(i); 
    } 
} 

嘗試在DartPad

參見

• https://www.dartlang.org/docs/tutorials/streams/
• https://www.dartlang.org/articles/creating-streams/

您不能在Dart中「等待」，特別是在瀏覽器中。

Dart還有async*生成器函數可用於創建流。例如見Async/Await feature in Dart 1.8

A 「天真」 翻譯形式await for(var event in someStream)

import 'dart:async'; 

main() { 
    StreamController<int> sc = new StreamController<int>(); 

    startProcessing(sc.stream); 

    for(int i = 0; i < 10; i++) { 
    sc.add(i); 
    } 
} 

Future startProcessing(Stream stream) async { 
    StreamSubscription subscr; 
    subscr = stream.listen((value) { 
    subscr.pause(); 
    new Future.delayed(new Duration(milliseconds: 500)).then((_) { 
     print('Processed $value'); 
     subscr.resume(); 
    }); 
    }); 
    //await for(int value in stream) { 
    // await new Future.delayed(new Duration(milliseconds: 500)).then((_) { 
    // print('Processed $value'); 
    // }); 
    //} 
} 

實際實現採用不同的方法

的方式的await-for循環實現使用一個事件緩衝區（以避免重複暫停和恢復）。

見https://github.com/dart-lang/sdk/issues/24956#issuecomment-157328619