Future<Stream<String>> observeQuery( String type, { DateTime? startDate, DateTime? endDate, }) { throw UnimplementedError('observeQuery() has not been implemented.'); }