langchain_community.utilities.nvidia_riva.AudioStream

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

包含流式音频的消息。

初始化队列。

属性

complete

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

empty

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

hungup

指示音频流是否挂断。

running

指示ASR流是否正在运行。

output

hangup

user_talking

user_quiet

方法

__init__([maxsize])

初始化队列。

aclose([timeout])

异步发送挂断信号。

aput(item[, timeout])

异步将新项放入队列。

close([timeout])

发送挂断信号。

put(item[, timeout])

将新项放入队列。

register(responses)

从提供的迭代器中清除响应并将它们放入队列。
参数

maxsize (int) –

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

初始化队列。

参数

maxsize (int) –

返回类型

None

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

异步发送挂断信号。

参数

timeout (Optional[int]) –

返回类型

None

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

异步将新项放入队列。

参数

  • item (Union[bytes, SentinelT]) –

  • timeout (Optional[int]) –

返回类型

None

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

发送挂断信号。

参数

timeout (Optional[int]) –

返回类型

None

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

将新项放入队列。

参数

  • item (Union[bytes, SentinelT]) –

  • timeout (Optional[int]) –

返回类型

None

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

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

参数

responses (Iterator[rasr.StreamingRecognizeResponse]) –

返回类型

None

使用 AudioStream 的示例