如何在flutter中缓存rxdart流以进行无限滚动

import 'package:rxdart/rxdart.dart';

BehaviorSubject<List<Item>> _itemSubject = BehaviorSubject<List<Item>>();

void fetchData() {
  // 异步获取数据的代码
  List<Item> items = await getDataFromApi();
  
  // 将获取到的数据添加到缓存流中
  _itemSubject.add(items);
}

Stream<List<Item>> get scrolledItems {
  // 创建一个新的流，当滚动到底部时触发
  return _scrollController.scrollEvent
      .where((event) => event.isAtBottom)
      .asyncMap((_) async {
        // 请求更多数据的代码
        List<Item> newItems = await fetchMoreData();
        
        // 获取缓存流中的当前数据
        List<Item> currentItems = _itemSubject.value ?? [];
        
        // 将新数据添加到当前数据后面
        List<Item> allItems = currentItems + newItems;
        
        // 将合并后的数据添加到缓存流中
        _itemSubject.add(allItems);
        
        // 返回合并后的数据
        return allItems;
      })
      .startWith(_itemSubject.value);  // 以当前缓存的数据作为初始数据
}

StreamBuilder<List<Item>>(
  stream: scrolledItems,
  builder: (context, snapshot) {
    if (snapshot.hasData) {
      return ListView.builder(
        itemCount: snapshot.data.length,
        itemBuilder: (context, index) {
          Item item = snapshot.data[index];
          return ListTile(title: Text(item.title));
        },
      );
    } else if (snapshot.hasError) {
      return Text('Error: ${snapshot.error}');
    } else {
      return CircularProgressIndicator();
    }
  },
);