streamQuery method

Implementation

@override
StreamIterator<RowData> streamQuery(String sql, [AnyList? parameters]) {
  lite.lastInsertRowId = 0;
  PreparedStatement ps = lite.prepareSQL(sql);
  IteratingCursor ic = ps.selectCursor(parameters ?? const []);
  return _SqliteStreamIterator(ic, onComplete: () => ps.close());
}