fetch method

void fetch()

Listen to snapshot from SnapshotListener.

Implementation

void fetch() {
  assert(_initLoaded == false);
  _disposer = _pagingListenerController.data.listen((event) {
    if (_limit != null) {
      _hasMore = event.length >= _limit!;
    } else {
      _hasMore = false;
    }
    _dataController.add(event);
  });

  _pagingListenerController.docChanges
      .where((event) => event.isNotEmpty)
      .pipe(_docChangesController);
  _pagingListenerController.onLoad.add(_limit);
  _initLoaded = true;
}