sink.addしているのにstreamでhasDataがfalseになってしまう.

Question

flutterでデータを取得しListViewで表示するというものをBlocパターンで作製しているのですが、sink.addのタイミングでデバッグで止めると値は取れているのですが、streambuilder内でhasDataがfalseになってしまいます。

どこが原因なのでしょうか？

構造はTabBarScreen -> Screenになっていてその中でListViewを表示しようとしています。
Providerはここで噛ませています。

lass TabInfo {
  String label;
  Widget widget;
  TabInfo(this.label, this.widget);
}

class TabBarScreen extends StatelessWidget {
  final List<TabInfo> _tabs = [
    TabInfo(
      "CARDS",
      CardBlocProvider(
        key: PageStorageKey<String>("key_card_screen"),
        bloc: CardBloc(),
        child: CardsScreen(),
      ),
      //...
    )
  ];

  @override
  Widget build(BuildContext context) {
    return DefaultTabController(
      length: _tabs.length,
      child: Scaffold(
        appBar: AppBar(
          leading: new Container(),
          title: Text(""),
          bottom: TabBar(
            isScrollable: true,
            tabs: _tabs.map((TabInfo tab) {
                return Tab(text: tab.label);
                }).toList(),
          ),
        ),

        body: TabBarView(children: _tabs.map((tab) => tab.widget).toList()),
      )
    );
  }
}

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

  @override
  _CardsScreenState createState() => new _CardsScreenState();
}

class _CardsScreenState extends State<CardsScreen> with AutomaticKeepAliveClientMixin<CardsScreen>{
  TextEditingController editingController = TextEditingController();

  //...

  @override
  Widget build(BuildContext context) {
    var bloc = CardBlocProvider.of(context);

    var searchView = TextField(
        //...
      );

    var stream = StreamBuilder(
      stream: bloc.cardsInitialStream,
      builder: (context, snap) {
        //ここでsnap.hasDataがfalseになってしまうためロードのままになってしまう。
        if(!snap.hasData) return LinearProgressIndicator();
        
        return ListView.builder(
          itemBuilder: (BuildContext context, int index){
            return Container(
              child:ListTile(
                //...
              ),
            );
          },
          itemCount: snap.data.list.length,
        );
      });

    var contentBody = Container(
      child: Column(
        children: <Widget>[
          Padding(
            padding: const EdgeInsets.all(8.0),
            child: stream
          ),
        ],
      ),
    );

    return Scaffold(
      body: contentBody,
      floatingActionButton: _createFloationgActionButton(),
    );
  }

sink.addのタイミングではデバッグでデータが渡ってきているが、streamで見るタイミングではhasDataはfalseになってしまう。

class CardBloc {
  final _cardsInitialPublishSubject = PublishSubject<CardListModel>();

  CardBloc() {
    fetchCards();
  }

  Stream<CardListModel> get cardsInitialStream => _cardsInitialPublishSubject.stream;

  Sink<CardListModel> get cardsInitialSink => _cardsInitialPublishSubject.sink;

  void fetchCards() async {
    final _cardsResponse = await CardRepository().fetchCardRepository();

    //ここをデバッグで見ると<CardListModel>のデータが渡ってきているが、Streamではデータが無いとなってしまう。
    cardsInitialSink.add(_cardsResponse);
  }

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

Answer 1

// PublishSubject<CardListModel>();
BehaviorSubject<CardListModel>();

これでどうでしょうか？

Comments

[hiro094]

ありがとうございます！表示できました！
初期値を使う場合はBehaviorSubjectでそうでなければPublishSubjectというのを見様見真似で使っていたのですが、今回初期値を使っていないのですが、hasDataがtrueにならないのはどのような原因だったのでしょうか・・・？

[iMASAKI]

アドバイスになるか分かりませんが・・・
PublishSubjectで作ったStreamを使ってウィジェットを表示しようとすると、
そのウィジェットが描画される前までにsink.addされたデータは受け取ることができません。

[hiro094]

ありがとうございます！
そうだったのですね・・・と言うことは初期値を特に入れる理由がなかったとしてもBehaviorSubjectを使う方が良いんですかね？
そうなるとPublishSubjectっていつ使うのでしょう・・・？(主の質問とは違いますが)

[iMASAKI]

Behavior Subjectはlisten前の状態を持ち、Publish Subjectは持たないという特徴があります。
なので僕はウィジェット間で状態を保持したいときはBehavior Subject。
ボタンなどでアクションの発生を伝えたいときはPublish Subjectという使い方をしています。

あくまで僕の使い方なので正しいかどうかは分かりませんが、参考になると嬉しいです。