queryToStream method
Stream<Map<String, dynamic> >
queryToStream(
- Map<
String, Object> data, { - Transaction? transaction,
Implementation
Stream<Map<String, dynamic>> queryToStream(
Map<String, Object> data, {
Transaction? transaction,
}) async* {
var streamStream = _queryToStreamStream(
data,
transaction: transaction,
);
await for (var batch in streamStream) {
var items = batch['result'];
for (var item in items) {
yield item as Map<String, dynamic>;
}
}
}