StreamEngine class final

Stream engine — reactive query lifecycle.

Manages the full lifecycle of reactive streams: registration, deduplication, initial query with dependency tracking, write invalidation, re-query with result-change detection, and per-subscriber buffered delivery.

Constructors

StreamEngine(Future<ReaderPool> _pool())

Properties

hashCode → int
The hash code for this object.
no setterinherited
length → int
Number of active stream entries.
no setter
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

close() → void
Closes all active streams and clears internal state.
handleDirtyTables(List<String> dirtyTables) → void
Called after every write — checks dirty tables against active streams and re-queries affected ones.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
stream(String sql, [List<Object?> parameters = const []]) → Stream<List<Map<String, Object?>>>
Create a reactive stream that emits query results and re-emits whenever the underlying tables change.
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited