fix(xapi): implement Throttling on Xapi/Remote read

@xen-orchestra/disk-transform/src/Throttled.mts

@@ -0,0 +1,26 @@
+import { Throttle } from '@vates/generator-toolbox'
+import { Disk, DiskBlock } from './Disk.mjs'
+import { DiskPassthrough } from './DiskPassthrough.mjs'
+
+export class ThrottledDisk extends DiskPassthrough {
+  #throttle: Throttle
+  constructor(source: Disk, throttle: Throttle) {
+    super(source)
+    this.#throttle = throttle
+  }
+  async buildDiskBlockGenerator(): Promise<AsyncGenerator<DiskBlock>> {
+    const generator = await this.source.buildDiskBlockGenerator()
+    //throttle want to be able to know the length of the data
+    async function* generatorWithLength() {
+      for await (const { index, data } of generator) {
+        yield {
+          index,
+          data,
+          length: data.length,
+        }
+      }
+    }
+    const throttledGenerator = this.#throttle.createThrottledGenerator(generatorWithLength())
+    return throttledGenerator as AsyncGenerator<DiskBlock>
+  }
+}

@xen-orchestra/disk-transform/src/index.mts

@@ -9,4 +9,5 @@ export { RawDisk } from './RawDisk.mjs'
 export { ReadAhead } from './ReadAhead.mjs'
 export { SynchronizedDisk } from './SynchronizedDisk.mjs'
 export { TimeoutDisk } from './Timeout.mjs'
+export { ThrottledDisk } from './Throttled.mjs'
 export { ProgressHandler } from './ProgressHandler.mjs'