StreamingQuery<T>.create constructor

StreamingQuery<T>.create({
  1. required String id,
  2. required QueryBuilder builder,
  3. required DeclarativeDatabase database,
  4. required T mapper(
    1. Map<String, Object?>
    ),
})

Factory constructor to create a streaming query

Implementation

factory StreamingQuery.create({
  required String id,
  required QueryBuilder builder,
  required DeclarativeDatabase database,
  required T Function(Map<String, Object?>) mapper,
}) {
  // Use schema-aware dependency analysis
  final analyzer = QueryDependencyAnalyzer(database.schema);
  final dependencies = analyzer.analyzeQuery(builder);

  return StreamingQuery._(
    id: id,
    builder: builder,
    dependencies: dependencies,
    database: database,
    mapper: mapper,
  );
}