langchain_community.utilities.nvidia_riva.AudioStream

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

包含流式音频的消息。

初始化队列。

Attributes

complete

指示音频流是否已挂断并已处理。

empty

指示输入流缓冲区是否为空。

hungup

指示音频流是否已挂断。

running

指示ASR流是否正在运行。

output

hangup

user_talking

user_quiet

Methods

__init__([maxsize])

初始化队列。

aclose([timeout])

异步发送挂断信号。

aput(item[, timeout])

异步将一个新项目放入队列中。

close([timeout])

发送挂断信号。

put(item[, timeout])

将一个新项目放入队列中。

register(responses)

从提供的迭代器中获取响应并将它们放入队列中。
Parameters

maxsize (int) –

Return type

None

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

初始化队列。

Parameters

maxsize (int) –

Return type

None

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

异步发送挂断信号。

Parameters

timeout (Optional[int]) –

Return type

None

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

异步将一个新项目放入队列中。

Parameters

  • item (Union[bytes, SentinelT]) –

  • timeout (Optional[int]) –

Return type

None

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

发送挂断信号。

Parameters

timeout (Optional[int]) –

Return type

None

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

将一个新项目放入队列中。

Parameters

  • item (Union[bytes, SentinelT]) –

  • timeout (Optional[int]) –

Return type

None

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

从提供的迭代器中获取响应并将它们放入队列中。

Parameters

responses (Iterator[rasr.StreamingRecognizeResponse]) –

Return type

None

Examples using AudioStream