subscribe method

QueryDispose subscribe(
  1. void listener(
    1. InfiniteQueryResult<TPage, TPageParam> result
    )
)

Subscribes to infinite query results.

Implementation

QueryDispose subscribe(
  void Function(InfiniteQueryResult<TPage, TPageParam> result) listener,
) {
  void update() => listener(current);
  final remove = _observer.subscribe((result) => listener(_result(result)));
  _listeners.add(update);
  return () {
    _listeners.remove(update);
    remove();
  };
}