> For clean Markdown of any page, append .md to the page URL.
> For a complete documentation index, see https://docs.nvidia.com/nemo/guardrails/llms.txt.
> For full documentation content, see https://docs.nvidia.com/nemo/guardrails/llms-full.txt.
> For AI client integration (Claude Code, Cursor, etc.), connect to the MCP server at https://docs.nvidia.com/nemo/guardrails/_mcp/server.

# nemoguardrails.integrations.langchain.providers.huggingface.streamers

## Module Contents

### Classes

| Name                                                                                                                            | Description                                                         |
| ------------------------------------------------------------------------------------------------------------------------------- | ------------------------------------------------------------------- |
| [`AsyncTextIteratorStreamer`](#nemoguardrails-integrations-langchain-providers-huggingface-streamers-AsyncTextIteratorStreamer) | Simple async implementation for HuggingFace Transformers streamers. |
| [`TextStreamer`](#nemoguardrails-integrations-langchain-providers-huggingface-streamers-TextStreamer)                           | -                                                                   |

### Data

[`TRANSFORMERS_AVAILABLE`](#nemoguardrails-integrations-langchain-providers-huggingface-streamers-TRANSFORMERS_AVAILABLE)

### API

```python
class nemoguardrails.integrations.langchain.providers.huggingface.streamers.AsyncTextIteratorStreamer(
    tokenizer: transformers.AutoTokenizer,
    skip_prompt: bool = False,
    decode_kwargs = {}
)
```

**Bases:** [TextStreamer](#nemoguardrails-integrations-langchain-providers-huggingface-streamers-TextStreamer)

Simple async implementation for HuggingFace Transformers streamers.

This follows closely how transformers.generation.streamers.TextIteratorStreamer works,
with minor modifications to make it async.

```python
nemoguardrails.integrations.langchain.providers.huggingface.streamers.AsyncTextIteratorStreamer.__aiter__()
```

```python
nemoguardrails.integrations.langchain.providers.huggingface.streamers.AsyncTextIteratorStreamer.__anext__()
```

async

```python
nemoguardrails.integrations.langchain.providers.huggingface.streamers.AsyncTextIteratorStreamer.on_finalized_text(
    text: str,
    stream_end: bool = False
)
```

Put the new text in the queue. If the stream is ending, also put a stop signal in the queue.

```python
class nemoguardrails.integrations.langchain.providers.huggingface.streamers.TextStreamer(
    args = (),
    kwargs = {}
)
```

```python
nemoguardrails.integrations.langchain.providers.huggingface.streamers.TRANSFORMERS_AVAILABLE = True
```