)`i ddZddlmZmZmZddlZedZGddeeZdS)z Resolver - An anyio-compatible future-like object for async result passing. This provides a simple way to pass a result (or exception) from one coroutine to another without depending on asyncio.Future. )GenericTypeVarcastNTcReZdZdZd dZdeddfdZdeddfdZdefd Z de fd Z dS) Resolverai A simple resolver for passing results between coroutines. Unlike asyncio.Future, this works with any anyio-compatible async backend. Usage: resolver: Resolver[str] = Resolver() # In one coroutine: resolver.set_result("hello") # In another coroutine: result = await resolver.wait() # returns "hello" returnNcRtj|_d|_d|_dS)N)anyioEvent_event_value _exceptionselfs z/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/mcp/shared/experimental/tasks/resolver.py__init__zResolver.__init__s!kmm $ 04valuec|jrtd||_|jdS)z)Set the result value and wake up waiters.Resolver already completedN)r is_set RuntimeErrorrset)rrs r set_resultzResolver.set_result$sF ;     =;<< <  rexcc|jrtd||_|jdS)z%Set an exception and wake up waiters.rN)r rrrr)rrs r set_exceptionzResolver.set_exception+sF ;     =;<< < rcK|jd{V|j|jtt|jS)z:Wait for the result and return it, or raise the exception.N)r waitrrrrrs rr z Resolver.wait2sNk         ? &/ !At{###rc4|jS)z/Return True if the resolver has been completed.)r rrs rdonez Resolver.done:s{!!###r)r N) __name__ __module__ __qualname____doc__rrr BaseExceptionrr boolr"rrrrs  5555 d4$A$$$$$d$$$$$$rr)r&typingrrrr rrr)rrr+s}*)))))))))  GCLL-$-$-$-$-$wqz-$-$-$-$-$r