rxdart replaySubject流到flutter中的listview

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

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  final ReplaySubject<List<String>> _dataSubject = ReplaySubject<List<String>>();

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('ReplaySubject to ListView'),
        ),
        body: StreamBuilder<List<String>>(
          stream: _dataSubject.stream,
          builder: (context, snapshot) {
            if (snapshot.hasData) {
              return ListView.builder(
                itemCount: snapshot.data.length,
                itemBuilder: (context, index) {
                  return ListTile(
                    title: Text(snapshot.data[index]),
                  );
                },
              );
            } else {
              return Center(
                child: CircularProgressIndicator(),
              );
            }
          },
        ),
        floatingActionButton: FloatingActionButton(
          onPressed: () {
            // 模拟异步数据更新
            Future.delayed(Duration(seconds: 2), () {
              List<String> newData = ['Item 1', 'Item 2', 'Item 3'];
              _dataSubject.add(newData);
            });
          },
          child: Icon(Icons.refresh),
        ),
      ),
    );
  }
}