42 lines
1.4 KiB
TypeScript
42 lines
1.4 KiB
TypeScript
import { Readable } from "node:stream";
|
|
import type { AbortSignalLike } from "@azure/abort-controller";
|
|
import type { TransferProgressEvent } from "@azure/core-rest-pipeline";
|
|
import type { BlobQueryError } from "../Clients.js";
|
|
export interface BlobQuickQueryStreamOptions {
|
|
/**
|
|
* An implementation of the `AbortSignalLike` interface to signal the request to cancel the operation.
|
|
* For example, use the @azure/abort-controller to create an `AbortSignal`.
|
|
*/
|
|
abortSignal?: AbortSignalLike;
|
|
/**
|
|
* Read progress event handler
|
|
*/
|
|
onProgress?: (progress: TransferProgressEvent) => void;
|
|
/**
|
|
* Callback to receive error events during the query operaiton.
|
|
*/
|
|
onError?: (error: BlobQueryError) => void;
|
|
}
|
|
/**
|
|
* ONLY AVAILABLE IN NODE.JS RUNTIME.
|
|
*
|
|
* A Node.js BlobQuickQueryStream will internally parse avro data stream for blob query.
|
|
*/
|
|
export declare class BlobQuickQueryStream extends Readable {
|
|
private source;
|
|
private avroReader;
|
|
private avroIter;
|
|
private avroPaused;
|
|
private onProgress?;
|
|
private onError?;
|
|
/**
|
|
* Creates an instance of BlobQuickQueryStream.
|
|
*
|
|
* @param source - The current ReadableStream returned from getter
|
|
* @param options -
|
|
*/
|
|
constructor(source: NodeJS.ReadableStream, options?: BlobQuickQueryStreamOptions);
|
|
_read(): void;
|
|
private readInternal;
|
|
}
|
|
//# sourceMappingURL=BlobQuickQueryStream.d.ts.map
|