langchain Architecture Docs
Home / Function/ _enqueue_stream() — langchain Function Reference

_enqueue_stream() — langchain Function Reference

Architecture documentation for the _enqueue_stream() function in shell_tool.py from the langchain codebase.

Function python LangChainCore Runnables

Entity Profile

Dependency Diagram

graph TD
  2f7426b9_6136_7c0a_bac5_0f65a2e30ac4["_enqueue_stream()"]
  cf4eeaa4_4bcc_69d9_a0f3_664b1eecb4e8["ShellSession"]
  2f7426b9_6136_7c0a_bac5_0f65a2e30ac4 -->|defined in| cf4eeaa4_4bcc_69d9_a0f3_664b1eecb4e8
  style 2f7426b9_6136_7c0a_bac5_0f65a2e30ac4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/langchain_v1/langchain/agents/middleware/shell_tool.py lines 412–415

    def _enqueue_stream(self, stream: Any, label: str) -> None:
        for line in iter(stream.readline, ""):
            self._queue.put((label, line))
        self._queue.put((label, None))

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does _enqueue_stream() do?
_enqueue_stream() is a function in the langchain codebase, defined in libs/langchain_v1/langchain/agents/middleware/shell_tool.py.
Where is _enqueue_stream() defined?
_enqueue_stream() is defined in libs/langchain_v1/langchain/agents/middleware/shell_tool.py at line 412.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free