Бесконечный цикл порхает, когда StreamBuilder внутри LayoutBuilder - PullRequest
Новая
       21

Бесконечный цикл порхает, когда StreamBuilder внутри LayoutBuilder

1 голос
/ 10 мая 2019

Итак, я делаю страницу с LayoutBuilder , как описано здесь

Внутри LayoutBuilder я поместил StreamBuilder с TextField работает на блоке класса RegistrationFormBlo c.Поток является BehaviorSubject

Когда кто-то помещает что-то на вход, он запускает функцию onChanged, которая является приемником для моего потока.Поэтому я добавляю значение в поток, затем передаю значение в StreamTransformer , чтобы проверить значение, а затем я позволяю StreamBuilder снова построить TextField с сообщением об ошибке (если значение недопустимо).

Это проблема, с которой начинается проблема.

Когда я нажимаю на TextField и вводю что-то, запускается бесконечный цикл, подобный следующему:

  • StreamBuilder видит новоезначение в потоке
  • StreamBuilder пытается перестроить TextField
  • Как-то, как это вызывает функцию компоновщика LayoutBuilder
  • Функция компоновщика LayoutBuilder снова создает StreamBuilder
  • StreamBuilder находит значение в потоке (из-за BehaviorSubject)
  • и все начинается снова с первого набранного в бесконечном цикле

Подсказка: Если я изменюПоведение объекта PublishSubject все в порядке

Подсказка 2: Если я полностью удаляю StreamBuilder и просто позволяю пустому TextField, вы можете видеть, что в каждой записи запускается функция построителя LayoutBuilder.Это нормальное поведение? 

import 'dart:async';

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

void main() => runApp(MyApp());

class MyApp extends StatelessWidget {
  // This widget is the root of your application.
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: MyHomePage(title: 'Flutter Demo Home Page'),
    );
  }
}

class MyHomePage extends StatefulWidget {
  MyHomePage({Key key, this.title}) : super(key: key);

  final String title;

  @override
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {


  SignupFormBloc _signupFormBloc;

  @override
  void initState() {
    super.initState();
    _signupFormBloc = SignupFormBloc();
  }

  @override
  Widget build(BuildContext context) {
    print('Build Run!!!!!');
    return Scaffold(
      appBar: AppBar(

        title: Text(widget.title),
      ),
      body: LayoutBuilder(
        builder: (BuildContext context, BoxConstraints viewportConstraints) {
          print('Layout Builder!!!');
          return SingleChildScrollView(
            child: ConstrainedBox(
              constraints: BoxConstraints(
                minHeight: viewportConstraints.maxHeight,
              ),
              child: IntrinsicHeight(
                child:         StreamBuilder<String>(
                  stream: _signupFormBloc.emailStream,
                  builder: (context, AsyncSnapshot<String> snapshot) {

                    return TextField(
                      onChanged: _signupFormBloc.onEmailChange,
                      keyboardType: TextInputType.emailAddress,
                      decoration: InputDecoration(
                        hintText: 'Email',
                        contentPadding: const EdgeInsets.symmetric(horizontal: 15, vertical: 18),
                        filled: true,
                        fillColor: Colors.white,
                        errorText: snapshot.error,
                        border: new OutlineInputBorder(
                          borderSide: BorderSide.none
                        ),
                      ),

                    );
                  }
                ),
              ),
            ),
          );
        },
      )
    );
  }

  @override
  void dispose() {
    _signupFormBloc?.dispose();
    super.dispose();
  }

}


class SignupFormBloc  {

  ///
  /// StreamControllers
  ///
  BehaviorSubject<String> _emailController = BehaviorSubject<String>();


  ///
  /// Stream with Validators
  ///
  Observable<String> get emailStream => _emailController.stream.transform(StreamTransformer<String,String>.fromHandlers(handleData: (email, sink){

    final RegExp emailExp = new RegExp(r"^[a-zA-Z0-9_.+-]+@[a-zA-Z0-9-]+\.[a-zA-Z0-9-.]+$");

    if (!emailExp.hasMatch(email) || email.isEmpty){
      print('has error');
      sink.addError('Email format is invalid');
    } else {
      sink.add(email);
    }
  }));


  ///
  /// Sinks
  ///
  Function(String) get onEmailChange => _emailController.sink.add;


  void dispose() {
    _emailController.close();
  }



}

1 Ответ

5 голосов
/ 10 мая 2019

Это происходит из-за неправильного использования потоков.

Виновником является эта строка: 

Observable<String> get emailStream => _emailController.stream.transform(...);

Проблема с этой строкой в ​​том, что она каждый раз создает новый поток.

Это означает, что bloc.emailStream == bloc.emailStream на самом деле ложно.

В сочетании с StreamBuilder это означает, что каждый раз, когда что-то просит StreamBuilder восстановить, последний перезапускает процесс прослушивания с нуля.

Вместо геттера вы должны создать поток один раз внутри тела конструктора вашего BLoC: 

class MyBloc {
  StreamController _someController;
  Stream foo;

  MyBloc() {
    foo = _someController.stream.transform(...);
  }
}
...