feat(sdk): add segment batch size and max concurrent segment batches options

lib/src/opentdf.ts

@@ -153,6 +153,12 @@ export type ReadOptions = {
   /** If set, prevents more than this number of concurrent requests to the KAS. */
   concurrencyLimit?: number;
 
+  /** Maximum number of payload segments to fetch and decrypt per batch. */
+  segmentBatchSize?: number;
+
+  /** Maximum number of segment batches that may be fetched concurrently. */
+  maxConcurrentSegmentBatches?: number;
+
   /** Type of key to use for wrapping responses. */
   wrappingKeyAlgorithm?: KasPublicKeyAlgorithm;
 };
@@ -495,7 +501,9 @@ class ZTDFReader {
   async decrypt(): Promise<DecoratedStream> {
     const {
       assertionVerificationKeys,
+      maxConcurrentSegmentBatches,
       noVerify: noVerifyAssertions,
+      segmentBatchSize,
       wrappingKeyAlgorithm,
     } = this.opts;
 
@@ -534,7 +542,9 @@ class ZTDFReader {
         keyMiddleware: async (k) => k,
         progressHandler: this.client.clientConfig.progressHandler,
         assertionVerificationKeys,
+        maxConcurrentSegmentBatches,
         noVerifyAssertions,
+        segmentBatchSize,
         wrappingKeyAlgorithm,
         fulfillableObligations: this.opts.fulfillableObligationFQNs || [],
       },

lib/tdf3/src/client/builders.ts

@@ -536,6 +536,8 @@ export type DecryptParams = {
   streamMiddleware?: DecryptStreamMiddleware;
   assertionVerificationKeys?: AssertionVerificationKeys;
   concurrencyLimit?: number;
+  segmentBatchSize?: number;
+  maxConcurrentSegmentBatches?: number;
   noVerifyAssertions?: boolean;
   wrappingKeyAlgorithm?: KasPublicKeyAlgorithm;
   fulfillableObligationFQNs?: string[];
@@ -725,6 +727,16 @@ class DecryptParamsBuilder {
     return this;
   }
 
+  withSegmentBatchSize(size: number): DecryptParamsBuilder {
+    this._params.segmentBatchSize = size;
+    return this;
+  }
+
+  withMaxConcurrentSegmentBatches(limit: number): DecryptParamsBuilder {
+    this._params.maxConcurrentSegmentBatches = limit;
+    return this;
+  }
+
   /**
    * Generate a parameters object in the form expected by <code>{@link Client#decrypt|decrypt}</code>.
    * <br/><br/>

lib/tdf3/src/client/index.ts

@@ -800,6 +800,8 @@ export class Client {
     assertionVerificationKeys,
     noVerifyAssertions,
     concurrencyLimit = 1,
+    maxConcurrentSegmentBatches,
+    segmentBatchSize,
     wrappingKeyAlgorithm,
     fulfillableObligationFQNs = [],
   }: DecryptParams): Promise<DecoratedReadableStream> {
@@ -836,7 +838,9 @@ export class Client {
         keyMiddleware,
         progressHandler: this.clientConfig.progressHandler,
         assertionVerificationKeys,
+        maxConcurrentSegmentBatches,
         noVerifyAssertions,
+        segmentBatchSize,
         wrappingKeyAlgorithm,
         fulfillableObligations: fulfillableObligationFQNs,
       })