你如何使用flutter_bloc包做Rx.CombineLatestStream

Question

我整理了一个示例应用程序，该应用程序使用流实现了用户名和密码字段，并使用验证转换进行了验证。我为此使用了 RxDart，并连接了“登录”按钮以根据 2 个流结果为真启用/禁用。

bloc.dart

  Stream<bool> get submitValidWithCombineLatestStream =>
  CombineLatestStream([email, password], (list) => true);

login_page.dart

 Widget submitButton(Bloc bloc) {
 return StreamBuilder(
   stream: bloc.submitValidWithCombineLatestStream,
   builder: (_, snapshot) {
    return RaisedButton(
      color: Colors.deepPurpleAccent,
      child: Text(
        'Submit',
        style: TextStyle(color: Colors.white),
      ),
      onPressed: !snapshot.hasData ? null : bloc.submit,
    );
  },
 );
}

我已经使用 flutter_bloc 编写了相同的示例应用程序，但我试图弄清楚如何使用组合最新流的任何 bloc 启用/禁用“登录”按钮。有人知道怎么做吗？

我意识到这完全是矫枉过正，但我​​正在尝试使用这个简单的示例来解决这个问题，我不确定一旦转换为 bloc (flutter_bloc) 后如何访问所有很酷的 RxDart 功能。我希望在不导入/使用 RxDart 的情况下两全其美。

这可能吗？

我正在寻找的一个例子是：

• 我正在构建一个需要 3 个不同后端调用的表单。我宁愿在所有 3 个调用都在工作时显示进度指示器，并阻止直到所有 3 个调用返回。我想通过 CombineLatestStreams 做到这一点，因为所有 3 个都返回 Steam Futures。

Answer 1

您的主要 bloc 类中的问题，请查看此 github 代码， https://github.com/hoc081098/flutter_validation_login_form_BLoC_pattern_RxDart

简而言之，你可以使用 CombineLatestStream 你可以在你的主要集团类中设置 像这样，

return LoginBloc._(
      emailChanged: emailS.add,
      passwordChanged: passwordS.add,
      submitLogin: () => submitLoginS.add(null),
      emailError$: emailError$,
      passwordError$: passwordError$,
      isLoading$: isLoadingS.stream,
      message$: message$,
      dispose: DisposeBag([...subjects, message$.connect()]).dispose,
    ); 

Answer 2

这就是使用 RxDart 将流与 bloc 组合的方式，如果侦听器中有新内容，您就会发出新值，仅此而已。 每当您想调用后端时，您都可以创建侦听器。

import 'dart:async';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:rxdart/rxdart.dart';

class TestState {
  final bool isValid;

  TestState(this.isValid);
}

class TestCubit extends Cubit<TestState> {
  final List<StreamSubscription> _ss = [];
  final _emailSubject = BehaviorSubject<String>.seeded(null);
  final _passwordSubject = BehaviorSubject<String>.seeded(null);

  TestCubit() : super(TestState(false)) {
    _ss.add(_subscribeToEmailAndPassword());
  }

  StreamSubscription _subscribeToEmailAndPassword() {
    return Rx.combineLatest([_emailSubject, _passwordSubject], (list) {
      if (list[0] != null && list[1] != null) {
        return true;
      }
      return false;
    }).listen((value) {
      emit(TestState(value));
    });
  }

  @override
  Future<void> close() async {
    _ss.forEach((e) async => await e.cancel());
    await super.close();
  }

  void emailFieldChange(String email) {
    _emailSubject.add(email);
  }

  void passwordFieldChange(String password) {
    _passwordSubject.add(password);
  }
}