AudioStream#

class langchain_community.utilities.nvidia_riva.AudioStream(maxsize: int = 0)[source]#

A message containing streaming audio.

Initialize the queue.

Attributes

`complete`	Indicate if the audio stream has hungup and been processed.
`empty`	Indicate in the input stream buffer is empty.
`hungup`	Indicate if the audio stream has hungup.
`running`	Indicate if the ASR stream is running.

Methods

`__init__`([maxsize])	Initialize the queue.
`aclose`([timeout])	Async send the hangup signal.
`aput`(item[, timeout])	Async put a new item into the queue.
`close`([timeout])	Send the hangup signal.
`put`(item[, timeout])	Put a new item into the queue.
`register`(responses)	Drain the responses from the provided iterator and put them into a queue.

__init__(maxsize: int = 0) → None[source]#

Initialize the queue.

async aclose(timeout: int | None = None) → None[source]#

Async send the hangup signal.

async aput(item: bytes | SentinelT, timeout: int | None = None) → None[source]#

Async put a new item into the queue.

Parameters:

Return type:

None

close(timeout: int | None = None) → None[source]#

Send the hangup signal.

put(item: bytes | SentinelT, timeout: int | None = None) → None[source]#

Put a new item into the queue.

Parameters:

Return type:

None

register(responses: Iterator[rasr.StreamingRecognizeResponse]) → None[source]#

Drain the responses from the provided iterator and put them into a queue.

Parameters:: responses (Iterator[rasr.StreamingRecognizeResponse]) –
Return type:: None

Examples using AudioStream