Flutter Await 回调不给出任何响应

Question

我仍然是 dart Flutter 的初学者，现在我正在尝试从 REST API 和 socket.IO 检索数据。这时候我有一个困惑的问题，我已经尝试在互联网上搜索3天，但没有解决方案。我有 async 和 await 脚本，但是我添加的函数 await 没有给出任何响应并且仍然暂停。

假设我有两个不同的文件，第一个是主文件，第二个是辅助文件。

ma​​in.dart

Future<List<ChatTile>> fetchChat(socketutil,id) async {

  socketutil.join(id); //STACK IN HERE
  SharedPreferences prefs = await SharedPreferences.getInstance();
  String messagePrefs = prefs.getString('messagePrefs');
  print("DUA");
  return await compute(parseListChat, messagePrefs);
}

helper.dart

Future<void> join(String id_room) async {
      String jsonData ='{"room_id" : "$id_room","user_id" : "5a91687811138e74009839c9","user_name" : "Denis Muhammad Ramdan","user_photo" : "photo.jpg","user_status" : "1"}';
      socketIO.sendMessage("join", jsonData, null);
      //subscribe event
      return await socketIO.subscribe("updateMessageList", (result) async {
        SharedPreferences prefs = await SharedPreferences.getInstance();
        await prefs.setString('messagePrefs', result);
        print('SATU');
        return await result;
      });
  }

我的问题是我的代码有问题，最好的方法是什么？

非常感谢，

Answer 1

我建议您将await_only_futures 添加到您的分析仪配置中

analysis_options.yaml

lint:
  rules:
   - await_only_futures

你也不需要return await something，因为你的函数已经返回了一个未来，这是多余的。

从我看到的 socketio subscribe 方法来看，它不会像您期望的那样返回结果，而是使用回调并且不会返回它 (https://pub.dartlang.org/documentation/flutter_socket_io/latest/flutter_socket_io/SocketIO/subscribe.html)

要处理这个问题，你应该使用Completer

final completer = Completer<String>()

socketIO.subscribe("updateMessageList", (result) async {
    SharedPreferences prefs = await SharedPreferences.getInstance();
    await prefs.setString('messagePrefs', result);
    socketIO.unSubscribe("updateMessageList");
    completer.complete(result);
  });

return completer.future;

你可能想在使用completer.completeError(error)时处理错误

更新

您也可以将订阅转换为 Dart Stream 以处理更多情况。

StreamController<String> controller;

Stream<String> get onUpdateMessageList {
   if (controller != null) return controller.stream;

   constroller = StreamController<String>.broadcast(
     onCancel: () => socketIO.unSubscribe("updateMessageList"),
   );

   socketIO.subscribe("updateMessageList", constroller.add);

   return controller.stream;
}



Future<StreamSubscription> join(String id_room) async {
  ...
  return onUpdateMessageList.listen((result) async {
   SharedPreferences prefs = await SharedPreferences.getInstance();
   await prefs.setString('messagePrefs', result);
  });
}