`langchain_community.utilities.nvidia_riva`.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.
`output`
`hangup`
`user_talking`
`user_quiet`

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: Optional[int] = None) → None[source]¶

Async send the hangup signal.

async aput(item: Union[bytes, SentinelT], timeout: Optional[int] = None) → None[source]¶

Async put a new item into the queue.

Parameters

Return type

None

close(timeout: Optional[int] = None) → None[source]¶

Send the hangup signal.

put(item: Union[bytes, SentinelT], timeout: Optional[int] = 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.

Examples using AudioStream¶