Method _writeChunksToRequest

source/core/index.ts:1919–1944

(buffer: Uint8Array, request: ClientRequest)

	};

	private async _writeChunksToRequest(buffer: Uint8Array, request: ClientRequest): Promise<void> {
		const chunkSize = 65_536; // 64 KB
		const isStale = () => this._isRequestStale(request);

		for (const part of chunk(buffer, chunkSize)) {
			if (isStale()) {
				return;
			}

			// eslint-disable-next-line no-await-in-loop
			await new Promise<void>((resolve, reject) => {
				this._writeRequest(part, undefined, error => {
					if (isStale()) {
						resolve();
						return;
					}

					if (error) {
						reject(error);
					} else {
						setImmediate(resolve);
					}
				}, request);
			});
		}
	}

	private _prepareCache(cache: string | StorageAdapter) {
		if (cacheableStore.has(cache)) {