Class AzureBlobProvider

constructor

• new AzureBlobProvider(
      options?: AzureBlobProviderOptions,
      now?: () => number,
  ): AzureBlobProvider

  Parameters

  • Optionaloptions: AzureBlobProviderOptions

    Azure connection/injection options

  • now: () => number = ...

    Wall-clock source (epoch ms) for SAS expiry. Injected by createProvider as runtime.now() (the only sanctioned clock outside packages/runtime). Defaults to () => 0 for direct construction.

  Returns AzureBlobProvider

OptionalisHealthy

connect

• connect(): Promise<void>

  Establishes the Azure client — injects the SDK lazily or uses injected client.

  Returns Promise<void>

delete

• delete(path: string): Promise<boolean>

  Deletes an object from Azure Blob Storage.

  Parameters

  • path: string

    Object key

  Returns Promise<boolean>

  true if deleted

disconnect

• disconnect(): Promise<void>

  Disconnect is a no-op for Azure (connectionless HTTP client).

  Returns Promise<void>

exists

• exists(path: string): Promise<boolean>

  Reports whether an object exists in Azure Blob Storage.

  Parameters

  • path: string

    Object key

  Returns Promise<boolean>

  true if present

get

• get(path: string): Promise<Uint8Array<ArrayBufferLike> | null>

  Retrieves an object from Azure Blob Storage; null when absent.

  Parameters

  • path: string

    Object key

  Returns Promise<Uint8Array<ArrayBufferLike> | null>

  The object bytes, or null

getSignedUrl

• getSignedUrl(path: string, options: { expiresIn: number }): Promise<string>

  Creates a SAS URL for an Azure Blob.

  Parameters

  • path: string

    Object key

  • options: { expiresIn: number }

    Expiry in seconds

  Returns Promise<string>

  The SAS URL

  Throws

  When the provider is not connected, or when the resolved client has no account key to sign with — both as REJECTIONS, never a synchronous throw, so a caller using .catch() sees them.

getStream

• getStream(
      path: string,
  ): Promise<ReadableStream<Uint8Array<ArrayBufferLike>> | null>

  Native stream download — adapts Azure readableStreamBody (Node Readable) into a web ReadableStream via async iteration.

  Cancellation-safe: the stream's cancel hook releases the iterator and destroys the underlying request, so a consumer cancelling mid-download neither leaks the connection nor crashes the process (previously the eager drain kept flowing after a cancel and the next chunk enqueued into the closed controller as an uncaught TypeError). Still an EAGER drain by documented contract — see provider-stream.ts and the README's per-provider table.

  Parameters

  • path: string

    Object key

  Returns Promise<ReadableStream<Uint8Array<ArrayBufferLike>> | null>

  A ReadableStream, or null if absent

isReady

• isReady(): boolean

  Reports readiness.

  Returns boolean

put

• put(path: string, data: Uint8Array, options?: PutObjectOptions): Promise<void>

  Stores an object in Azure Blob Storage, recording any content type and user metadata on the blob so a SAS URL serves it under the right type.

  Azure carries the content type inside blobHTTPHeaders rather than beside the metadata, so the two land in different places on the same call.

  Parameters

  • path: string

    Object key

  • data: Uint8Array

    Object bytes

  • Optionaloptions: PutObjectOptions

    Object attributes to record with the bytes

  Returns Promise<void>