close method

Future<void> close()

Stops observation after any active refresh and closes updates.

Implementation

Future<void> close() async {
  if (_closed) return;
  _closed = true;
  await _subscription?.cancel();
  _subscription = null;
  await _queue.close();
  for (final waiter in _reconcileWaiters) {
    if (!waiter.isCompleted) {
      waiter.completeError(StateError('Watched Eagle library was closed'));
    }
  }
  _reconcileWaiters.clear();
  await _updates.close();
}