watch<T> method

@override Stream<T> watch<T>(Endpoint endpoint, { Map<String, dynamic>? queryParams, Map<String, String>? pathParams, })

Watches an endpoint for changes (Streams).

Implementation

@override
Stream<T> watch<T>(
  Endpoint endpoint, {
  Map<String, dynamic>? queryParams,
  Map<String, String>? pathParams,
}) {
  if (_mockStreams.containsKey(endpoint.id)) {
    return _mockStreams[endpoint.id]!.stream.map((data) {
      return endpoint.parser != null
          ? endpoint.parser!(data) as T
          : data as T;
    });
  }

  throw StateError('No mock stream set for endpoint: ${endpoint.id}. '
      'Call mockStream<T>("${endpoint.id}") first.');
}