音频流#

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

包含流式音频的消息。

初始化队列。

属性

complete

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

empty

指示输入流缓冲区为空。

hungup

指示音频流是否已挂断。

running

指示ASR流是否正在运行。

方法

__init__([maxsize])

初始化队列。

aclose([timeout])

异步发送挂断信号。

aput(item[, timeout])

异步将新项目放入队列。

close([timeout])

发送挂断信号。

put(item[, timeout])

将新项目放入队列。

register(responses)

从提供的迭代器中排出响应并将其放入队列中。
Parameters:

maxsize (int)

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

初始化队列。

Parameters:

maxsize (int)

Return type:

无

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

异步发送挂断信号。

Parameters:

timeout (int | None)

Return type:

无

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

异步将新项目放入队列。

Parameters:

  • 项目 (字节 | SentinelT)

  • timeout (int | None)

Return type:

无

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

发送挂断信号。

Parameters:

timeout (int | None)

Return type:

无

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

将新项目放入队列中。

Parameters:

  • 项目 (字节 | SentinelT)

  • timeout (int | None)

Return type:

无

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

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

Parameters:

responses (Iterator[rasr.StreamingRecognizeResponse])

Return type:

无

使用AudioStream的示例