Toggle Menu
Prev Up Next

# `langchain_community.utilities.nvidia_riva`.AudioStream

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

  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.

  Parameters

    maxsize (int) –

  __init__(maxsize: int = 0) → None

    Initialize the queue.

    Parameters

      maxsize (int) –

    Return type

      None

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

    Async send the hangup signal.

    Parameters

      timeout (Optional[int]) –

    Return type

      None

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

    Async put a new item into the queue.

    Parameters

      - item (Union[bytes, SentinelT]) –

      - timeout (Optional[int]) –

    Return type

      None

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

    Send the hangup signal.

    Parameters

      timeout (Optional[int]) –

    Return type

      None

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

    Put a new item into the queue.

    Parameters

      - item (Union[bytes, SentinelT]) –

      - timeout (Optional[int]) –

    Return type

      None

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

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

    Parameters

      responses (Iterator[rasr.StreamingRecognizeResponse]) –

    Return type

      None

# Examples using AudioStream

- send data into the chain