uebu-kaihatsu.jp.net

Flutter:悪い状態:ストリームは既にリッスンされています


    class MyPage extends StatelessWidget {
      @override
      Widget build(BuildContext context) {
        return DefaultTabController(
          length: 2,
          child: new Scaffold(
            appBar: TabBar(
              tabs: [
                Tab(child: Text("MY INFORMATION",style: TextStyle(color: Colors.black54),)),
                Tab(child: Text("WEB CALENDER",style: TextStyle(color: Colors.black54),)),
              ],
            ),
            body:PersonalInformationBlocProvider(
              movieBloc: PersonalInformationBloc(),
              child: TabBarView(
                children: [
                  MyInformation(),
                  new SmallCalendarExample(),
                ],
              ),
            ),
          ),
        );
      }
    }

    class MyInformation extends StatelessWidget{
      // TODO: implement build
      var deviceSize;

      //Column1
      Widget profileColumn(PersonalInformation snapshot) => Container(
        height: deviceSize.height * 0.24,
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            Row(
              mainAxisAlignment: MainAxisAlignment.spaceEvenly,
              children: <Widget>[
                Container(
                  decoration: BoxDecoration(
                    borderRadius:
                    new BorderRadius.all(new Radius.circular(50.0)),
                    border: new Border.all(
                      color: Colors.black,
                      width: 4.0,
                    ),
                  ),
                  child: CircleAvatar(
                    backgroundImage: NetworkImage(
                        "http://www.binaythapa.com.np/img/me.jpg"),
                    foregroundColor: Colors.white,
                    backgroundColor: Colors.white,
                    radius: 40.0,
                  ),
                ),
                ProfileTile(
                  title: snapshot.firstName,
                  subtitle: "Developer",
                ),
                SizedBox(
                  height: 10.0,
                ),
              ],
            )
          ],
        ),
      );
      Widget bodyData(PersonalInformation snapshot) {
        return SingleChildScrollView(
            child: Column(
              children: <Widget>[
                profileColumn(snapshot)
              ],
            ),
        );
      }


      @override
      Widget build(BuildContext context) {
        final personalInformationBloc = PersonalInformationBlocProvider.of(context);

        deviceSize = MediaQuery.of(context).size;
        return StreamBuilder(
            stream: personalInformationBloc.results,
            builder: (context,snapshot){
              if (!snapshot.hasData)
                return Center(
                  child: CircularProgressIndicator(),
                );
              return bodyData(snapshot.data);
            }
        );
      }
    }


Rest APIからデータを取得するためにBlocパターンを使用しています(jsonからオブジェクト全体を呼び出し、解析したユーザー名のみ)。このページは、MyIformationとSmallCalendarの2つのタブで構成されています。アプリを実行すると、データが正しく取得され、すべてが正常に取得されます。タブ2に移動してタブ1に戻ると、タブ1の画面全体が赤になり、エラーが表示されます:Bad state: Stream has already been listened to.

25

この問題は、コントローラーをブロックに配置しないことが原因でした。

  void dispose() {
    monthChangedController.close();
    dayPressedController.close();
    resultController.close();
  }
5

以下を使用する必要があります。

StreamController<...> _controller = StreamController<...>.broadcast();
25
amenbo

Streamの最も一般的な形式は、一度に1回だけ聞くことができます。複数のリスナーを追加しようとすると、スローされます

悪い状態:ストリームは既にリッスンされています

このエラーを防ぐには、broadcastStreamを公開します。 myStream.asBroadcastStreamを使用して、ストリームをブロードキャストに変換できます

これは、Streamを公開するクラス内で実行する必要があります。 StreamBuilderのパラメーターとしてではありません。 asBroadcastStreamは内部的に元のストリームをリッスンしてブロードキャストストリームを生成するため、同じストリームでこのメソッドを2回呼び出すことはできません。

11
Rémi Rousselet

私の場合、同じストリームの同じウィジェットで同じコード行myStream.listen()が2回呼び出されたため、このエラーが発生していました。どうやらこれは許可されていません!

私にとってそれを修正したのは、ブロードキャストコントローラーとしてストリームコントローラーを作成することです。

var myStreamController = StreamController<bool>.broadcast();

そして

ストリームをブロードキャストストリームとして使用します。

myStreamController.stream.asBroadcastStream().listen(onData);
2
Samer s Salib

StreamBuilderのObservable.combineLatest2の結果をDrawerに使用したときに、同じ問題が発生しました。

flutter:悪い状態:ストリームは既にリッスンされています。

私に関しては、最良の解決策はこの組み合わせの結果を新しいBehaviorSubjectに追加し、新しいものをリッスンしました。

古いものを聞くことを忘れないでください!!!

class VisitsBlocc extends Object {
    Map<Visit, Location> visitAndLocation;

    VisitsBloc() {
        visitAndLocations.listen((data) {
            visitAndLocation = data;
        });
    }

    final _newOne = new BehaviorSubject<Map<Visit, Location>>();

    Stream<Map<Visit, Location>> get visitAndLocations => Observable.combineLatest2(_visits.stream, _locations.stream, (List<vis.Visit> visits, Map<int, Location> locations) {
        Map<vis.Visit, Location> result = {};

        visits.forEach((visit) {
            if (locations.containsKey(visit.skuLocationId)) {
                result[visit] = locations[visit.skuLocationId];
            }
        });

        if (result.isNotEmpty) {
            _newOne.add(result);
        }
    });
}

UIが遅くなるため、.broadcastを使用しませんでした。

0
Serhii