batchStream method

Future<BatchStream> batchStream({
  1. int batchRows = 65536,
  2. int capacity = 2,
  3. ExecutionEngine engine = ExecutionEngine.auto,
})

Asynchronous transport variant of batchStreamSync.

Implementation

Future<BatchStream> batchStream({
  int batchRows = 65536,
  int capacity = 2,
  ExecutionEngine engine = ExecutionEngine.auto,
}) async {
  _validateBatchStreamLimits(batchRows, capacity);
  final lease = _owner.lease('LazyFrame');
  try {
    return _runtime._adoptBatchStream(
      await _runtime._client.invoke('lazyBatchStream', {
        'input': lease.handle.toString(),
        'batchRows': batchRows,
        'capacity': capacity,
        'engine': engine.wireName,
      }),
    );
  } finally {
    lease.end();
  }
}