queryToStream method

Stream<Map<String, dynamic>> queryToStream(
  1. Map<String, Object> data, {
  2. 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>;
    }
  }
}