如何在 Getx Rx<String> 上添加错误并在流构建器上获取它？

问题描述

我尝试在 catch 块的 Getx Rx 上添加错误并在我的流构建器上获取它，但出现以下错误并且进度指示器永远运行：

[GETX] GOING TO ROUTE /
[GETX] REMOVING ROUTE /login
E/flutter ( 5129): [ERROR:flutter/lib/ui/ui_dart_state.cc(186)] Unhandled Exception: NoSuchMethodError: Closure call with mismatched arguments: function '_StreamBuilderBaseState._subscribe.<anonymous closure>'
E/flutter ( 5129): Receiver: Closure: (Object,StackTrace) => Null
E/flutter ( 5129): Tried calling: _StreamBuilderBaseState._subscribe.<anonymous closure>("error")
E/flutter ( 5129): Found: _StreamBuilderBaseState._subscribe.<anonymous closure>(Object,StackTrace) => Null
E/flutter ( 5129): #0      Object.noSuchMethod (dart:core-patch/object_patch.dart:54:5)
E/flutter ( 5129): #1      GetStream._notifyError  [package:get/…/rx_stream/get_stream.dart]
E/flutter ( 5129): #2      GetStream.addError      [package:get/…/rx_stream/get_stream.dart]
E/flutter ( 5129): #3      _RxImpl.addError        [package:get/…/rx_core/rx_impl.dart]
E/flutter ( 5129): #4      HomeController.load     [package:testegetx/main.dart]
E/flutter ( 5129): <asynchronous suspension>
E/flutter ( 5129):

这是我用来重现错误的代码：

import 'package:flutter/material.dart';
import 'package:get/get.dart';

void main() {
  runApp(App());
}

class App extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return GetMaterialApp(
      title: 'App',initialRoute: '/login',getPages: [
        GetPage(name: '/login',page: () => LoginPage()),GetPage(name: '/',page: () => HomePage(HomeController())),],);
  }
}

class LoginPage extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return Scaffold(
      body: Center(
        child: ElevatedButton(
          onPressed: () {
            Get.offAllNamed('/');
          },child: Text('Go Home'),),);
  }
}

class HomeController {
  final _text = Rx<String>();
  Stream<String> get textStream => _text.stream;
  Future<void> load() async {
    try {
      await Future.delayed(Duration(seconds: 2));
      throw Error();
    } catch (e) {
      _text.addError('error');
    }
  }
}

class HomePage extends StatelessWidget {
  final HomeController controller;
  HomePage(this.controller);
  @override
  Widget build(BuildContext context) {
    controller.load();
    return Scaffold(
      body: StreamBuilder<String>(
          stream: controller.textStream,builder: (context,snapshot) {
            Widget child;
            if (snapshot.hasError) {
              child = Text(snapshot.error);
            } else if (!snapshot.hasData) {
              child = Text('loading...');
            } else {
              child = Text(snapshot.data);
            }
            return Center(
              child: child,);
          }),);
  }
}

更新

我转到了稳定频道，并且在 comment 中得到了回答。

解决方法

因此，对于您在这里所拥有的内容，您并没有真正使用 GetX，您基本上是在使用标准的 dart 流。您不需要传递 Getx 控制器。我建议阅读他们的文档以进行适当的控制器初始化并访问应用程序中的任何位置。

在使用 Getx 加载数据时显示“加载”的最简单方法是使用 RxBool 和 GetX 小部件，该小部件对可观察变量（GetX 或 Obx 小部件）做出反应。如果重点是访问变量的值并将其显示在屏幕上，我在这里也看不到 getter 的值。 HomeController 的 onInit 中的句柄错误将捕获任何流错误，您可以在那里做您需要做的事情。但是下面的代码将在您的加载函数中显示指定持续时间的“正在加载...”。

class HomeController extends GetxController {
  RxString text = ''.obs;
  RxBool isLoading = true.obs;

  @override
  onInit() {
    super.onInit();
    text.stream.handleError(() {
      // handle your error here
    });
  }

  Future<void> load() async {
    try {
      await Future.delayed(Duration(seconds: 2));
      isLoading.value = false;
      throw Error();
    } catch (e) {
      text.addError('error');
    }
  }
}

class HomePage extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    final controller = Get.put(HomeController());
    controller.load();
    return Scaffold(
      body: Obx(() => Center(
            child: controller.isLoading.value
                ? Text('loading...')
                : Text(controller.text.value),)),);
  }
}