hoc081098 / hoc081098/sqlbrite

feat: `queryCursorAsStream`

Open
#42 0 comments 0 reactions 1 assignee Claimed by @hoc081098 View on GitHub
enhancement
Dominant language
Dart
Stars
31
Forks
6
PR merge metrics
No merged PRs in 30d

Description

https://github.com/ReactiveX/rxdart/pull/696

```dart
Stream queryCursorAsStream(
String table, {
bool? distinct,
List? columns,
String? where,
List? whereArgs,
String? groupBy,
String? having,
String? orderBy,
int? limit,
int? offset,
int? bufferSize,
}) =>
Rx.using(
() => queryCursor(
table,
distinct: distinct,
columns: columns,
where: where,
whereArgs: whereArgs,
groupBy: groupBy,
having: having,
orderBy: orderBy,
limit: limit,
offset: offset,
bufferSize: bufferSize,
),
(cursor) async* {
while (await cursor.moveNext()) {
yield cursor.current;
}
},
(cursor) => cursor.close(),
);
```

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.