StreamStartBatchedRequest.withParamsBuffer constructor

StreamStartBatchedRequest.withParamsBuffer(
  1. int requestId,
  2. int connectionId,
  3. String sql, {
  4. int fetchSize = 1000,
  5. int chunkSize = 64 * 1024,
  6. int resultEncodingWire = 0,
  7. Uint8List? paramsBuffer,
})

Implementation

factory StreamStartBatchedRequest.withParamsBuffer(
  int requestId,
  int connectionId,
  String sql, {
  int fetchSize = 1000,
  int chunkSize = 64 * 1024,
  int resultEncodingWire = 0,
  Uint8List? paramsBuffer,
}) {
  if (paramsBuffer != null) {
    final transferableParams = transferableIsolatePayload(paramsBuffer);
    if (transferableParams != null) {
      return StreamStartBatchedRequest._transferable(
        requestId,
        connectionId,
        sql,
        transferableParams,
        fetchSize: fetchSize,
        chunkSize: chunkSize,
        resultEncodingWire: resultEncodingWire,
      );
    }
  }
  return StreamStartBatchedRequest(
    requestId,
    connectionId,
    sql,
    fetchSize: fetchSize,
    chunkSize: chunkSize,
    resultEncodingWire: resultEncodingWire,
    paramsBuffer: paramsBuffer,
  );
}