从异步方法返回多个结果？

Question

我目前有一个看起来像这样的方法：

typedef void MyCallback(int status, String body);


void makeRequest(String url, MyCallback callback) async {
  if( someCondition ){
    callback(1, '');
  }

  Response response = await http.get(url);

  if( response.httpCode == 200 ){
    callback(2, response.body);
  }
  else{
    callback(3, '');
  }
}

我想摆脱回调，以便等待makeRequest 的结果。但如果我只是让它返回一个Future，我将无法返回不止一次。

我研究过使用流，但它似乎有点复杂。所以基本上我正在寻找像Future 这样方便的东西，但它可能会收到“部分结果”，即不止一次收到结果。举例说明：

MultiFuture<int> makeRequest(String url){
  MultiFuture result = new MultiFuture();

  if( someCondition ){
    result.value(1);
  }

  http.get(url).then((response){
    if( response.httpCode == 200 ){
      result.value(2);
    }
    else{
      result.value(3);
    }

    result.finish();
  });


  return result;
}




MultiFuture requestResult = makeRequest('https://example.com');

await requestResult.onValue((int value){
  print('value: $value');
});      
// When result.finish() is called, the await is finished

使用流是我的最佳选择，还是有某种我不知道的MultiFuture？

Answer 1

从异步方法返回多个结果正是流的作用。这是我根据您的代码制作的示例，以便您更容易理解它的工作原理：

class MultiFuture {
  StreamController<int> _resultController = StreamController<int>();
  Stream<int> get requestResult => _resultController.stream;

  void makeRequest(String request) async {
    if (true) {
      _resultController.sink.add(1);
    }

    // mock request
    await Future.delayed(Duration(seconds: 3));

    if (true) {
      _resultController.sink.add(2);
    } else {
      _resultController.sink.add(3);
    }
  }

  void example() {
    makeRequest("https://example.com");

    requestResult.listen((value) {
      print('value: $value');
    });
  }
}

您可以调用 MultiFuture().example(); 对其进行测试；

---

但我建议您观看这些简单的短片以获得更好的想法： Async Coding With Dart