o *i @s@dZddlmZmZmZddlZedZGdddeeZdS)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. )GenericTypeVarcastNTc@sZeZdZdZdddZdeddfddZd eddfd d Zdefd d Z de fddZ 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" returnNcCst|_d|_d|_dS)N)anyioEvent_event_value _exceptionselfrc/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/mcp/shared/experimental/tasks/resolver.py__init__s  zResolver.__init__valuecC&|jr td||_|jdS)z)Set the result value and wake up waiters.Resolver already completedN)r is_set RuntimeErrorr set)rrrrr set_result$ zResolver.set_resultexccCr)z%Set an exception and wake up waiters.rN)r rrr r)rrrrr set_exception+rzResolver.set_exceptioncs.|jIdH|jdur|jtt|jS)z:Wait for the result and return it, or raise the exception.N)r waitr rrr r rrrr2s   z Resolver.waitcCs |jS)z/Return True if the resolver has been completed.)r rr rrrdone:s z Resolver.done)rN) __name__ __module__ __qualname____doc__rrr BaseExceptionrrboolrrrrrrs r)r!typingrrrrrrrrrrs