streamMultiStartAsync method

int? streamMultiStartAsync(int connectionId, String sql, { int fetchSize = 1000, int chunkSize = 64 * 1024, int resultEncodingWire = 0, })

Async variant of streamMultiStartBatched. Status is observable via the existing streamPollAsync.

Implementation

int? streamMultiStartAsync(
  int connectionId,
  String sql, {
  int fetchSize = 1000,
  int chunkSize = 64 * 1024,
  int resultEncodingWire = 0,
}) {
  if (!_bindings.supportsAsyncMultiResultStream) return null;
  return _withSql<int>(
    sql,
    (sqlPtr) {
      if (resultEncodingWire != 0) {
        final optionsId = _bindings.odbc_stream_multi_start_async_options(
          connectionId,
          sqlPtr,
          fetchSize,
          chunkSize,
          resultEncodingWire,
        );
        if (optionsId != null) {
          return optionsId;
        }
      }
      return _bindings.odbc_stream_multi_start_async(
        connectionId,
        sqlPtr,
        chunkSize,
      );
    },
  );
}