i PdZddlmZmZmZddlZedZGddeeZy)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. )GenericTypeVarcastNTcPeZdZdZd dZdeddfdZdeddfdZdefd Z de fd Z y) 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|_y)N)anyioEvent_event_value _exceptionselfs f/root/aria/mcps/aria-brain/venv/lib/python3.12/site-packages/mcp/shared/experimental/tasks/resolver.py__init__zResolver.__init__skkm $ 04valuec|jjr td||_|jj y)z)Set the result value and wake up waiters.Resolver already completedN)r is_set RuntimeErrorrset)rrs r set_resultzResolver.set_result$s3 ;;   ;< <  rexcc|jjr td||_|jj y)z%Set an exception and wake up waiters.rN)r rrrr)rrs r set_exceptionzResolver.set_exception+s3 ;;   ;< < rcK|jjd{|j |jtt|j S76w)z:Wait for the result and return it, or raise the exception.N)r waitrrrrrs rr z Resolver.wait2sFkk   ?? &// !At{{## !sAA7Ac6|jjS)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"rrrrsJ 5 d4$A$$d$rr)r&typingrrrr rrr)rrr+s.*)  CL-$wqz-$r