insertStream method

Future<void> insertStream({
  1. required String table,
  2. required Stream<List<Map<String, dynamic>>> chunks,
  3. List<String>? namespace,
})

Implementation

Future<void> insertStream({required String table, required Stream<List<Map<String, dynamic>>> chunks, List<String>? namespace}) async {
  final input = _DatabaseWriteInputStream(start: {"kind": "start", "table": table, "namespace": namespace}, chunks: chunks);
  await _drainWriteStream("insert", input);
}