1

我尝试在块的 Getx Rx 上添加错误catch并在我的流生成器​​上获取它，但是得到以下错误并且进度指示器一直运行：

[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,
            );
          }),
    );
  }
}

更新

我搬到了稳定的频道，它在评论中得到了回答。

4

1 回答 1

1

因此，您在这里所拥有的并没有真正使用 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),
          )),
    );
  }
}
于 2021-02-09T19:06:35.347 回答