executeAll method

  1. @override
Stream<StreamedResults> executeAll(
  1. Iterable<Iterable> values
)
override

Executes the statement multiple times with the given values.

Implementation

@override
Stream<StreamedResults> executeAll(Iterable<Iterable> values) {
  var controller = StreamController<StreamedResults>();
  Future.microtask(() async {
    try {
      for (int i = 0; i < values.length; i++) {
        Iterable v = values.elementAt(i);
        controller.add(await _conn._executePrepared(_query, v));
      }
    } catch (e, st) {
      controller.addError(e, st);
    }
  });
  return controller.stream;
}