observe method

  1. @override
Stream<ObserveEvent> observe(
  1. ObserveRequest request
)
override

Watches ObserveRequest.domain for changes. Emits ObserveEvents until the subscription is cancelled. Unsupported platforms emit a single SimpleQueryError with code: notSupported.

Implementation

@override
Stream<ObserveEvent> observe(ObserveRequest request) {
  observeCalls += 1;
  observeRequests.add(request);
  return _observeStream;
}