flutter - 带有流听的比赛条件

Question

我有一个异步功能，如下所示。但是，在完成流侦听之前，内容将返回null。

我开始尝试使用Future.delayed，但是想得更好，想问一下是否有更好的方法来确保它异步？

import 'package:googleapis/drive/v3.dart' as ga;

static Future<String> getContentsFromFile() async {
String content;

ga.Media mediaResponse = await drive.files.get(fileId);

mediaResponse.stream.listen((data) {
    print("DataReceived: "+data);
    content = data
  }, onDone: () async {
    print("Task Done");
  }, onError: (error) {
    print("Some Error");
  });
return content;
}

我像这样调用函数

String content = await getContentsFromFile();

Answer 1

编辑:使示例更完整，并处理错误和部分内容。

您可以将Completer用于这种控制流:

import 'dart:async';
import 'package:googleapis/drive/v3.dart' as ga;

static Future<String> getContentsFromFile() async {
  Completer<String> completer = Completer();
  String content = "";

  ga.Media mediaResponse = await drive.files.get(fileId);

  mediaResponse.stream.listen((data) {
    print("DataReceived: "+data);
    content += data;
  }, onDone: () async {
    print("Task Done");
    completer.complete(content);
  }, onError: (error) {
    print("Some Error");
    completer.completeError(error);
  });

  return completer.future;
}