aclosing

class langchain_core.utils.aiter.aclosing(thing: AsyncGenerator[Any, Any] | AsyncIterator[Any])

Async context manager to wrap an AsyncGenerator that has a aclose() method.

Code like this:

async with aclosing(<module>.fetch(<arguments>)) as agen:

<block>

is equivalent to this:

agen = <module>.fetch(<arguments>) try:

<block>

finally:

await agen.aclose()

Create the context manager.

Parameters:

thing (AsyncGenerator[Any, Any] | AsyncIterator[Any]) – The resource to wrap.

Methods

__init__(thing)

Create the context manager.

__init__(thing: AsyncGenerator[Any, Any] | AsyncIterator[Any]) → None

Create the context manager.

Parameters:

thing (AsyncGenerator[Any, Any] | AsyncIterator[Any]) – The resource to wrap.

Return type:

None