sqlStream method

Stream<List<Map<String, dynamic>>> sqlStream({
  1. required String query,
  2. required List<TableRef> tables,
  3. Map<String, dynamic>? params,
})

Implementation

Stream<List<Map<String, dynamic>>> sqlStream({required String query, required List<TableRef> tables, Map<String, dynamic>? params}) {
  return _streamRows("sql", {
    "kind": "start",
    "query": query,
    "tables": tables.map((table) => table.toJson()).toList(growable: false),
    "params_json": params == null ? null : jsonEncode(_encodeRecordValue(params)),
  });
}