o 6Wj4@s"UddlmZddlZddlmZmZmZmZmZm Z ddl m Z ddl m Z er1ddlmZmZgdZee gd fZd ed < ee ge d fZd ed < GdddZee egd fZd ed<ee ege d fZd ed<eeeefZd ed<d#ddZd$ddZd%dd Zd%d!d"ZdS)&) annotationsN) TYPE_CHECKINGAnyUnionCallableIterable Awaitable) TypeAlias) APIRequest) APIResponseAsyncAPIResponse) MiddlewareCallNext AsyncCallNextMiddlewareCallableAsyncMiddlewareCallableMiddlewareInputAPIResponse[Any]r rAsyncAPIResponse[Any]rc@s$eZdZdZddd Zdd d ZdS)rzBase class for client-level middleware. Subclass and override `handle` (used by the sync client) and/or `handle_async` (used by the async client). The default implementations delegate straight to the rest of the chain. requestr call_nextrreturnrcCs||SNselfrrrrd/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anthropic/_middleware.pyhandle6szMiddleware.handlerrcs||IdHSrrrrrr handle_async9szMiddleware.handle_asyncN)rr rrrr)rr rrrr)__name__ __module__ __qualname____doc__rrrrrrr.s rrrr middlewareobjectrstrcCs6t|tr t|jSt|dd}t|tr|St|S)Nr ) isinstancertyper getattrr&repr)r$namerrr_middleware_nameBs   r,objboolcCs,t|rdSt|dd}|duot|S)zWhether calling the given object returns a coroutine. Unlike `inspect.iscoroutinefunction(obj)` this also handles class instances that define an async `__call__` method. T__call__N)inspectiscoroutinefunctionr))r-callrrr_is_async_callableIs  r3Iterable[MiddlewareInput]NonecCs|D]H}t|tr.t|jtjurtdt|dtt|jr-tdt|dqt|s)r$r%rr&)r-r%rr.)r$r4rr5) __future__rr0typingrrrrrrtyping_extensionsr _requestr _responser r __all__r__annotations__rrrrrr,r3r<r>rrrrs(