a 'j@sddlmZddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z ddlZddlmZmZerzddlmZmZedZndd Zgd Ze d d d Ze dZe dddddddZe dddddddZdddddddZe dddddddZe dddddddZdddddd dZejd!d!d d"Gd#d$d$eje eZeejd d!d d%Gd&d'd'eee eZeejd d!d d%Gd(ddee Ze eeefZ dS))) annotationsN) TYPE_CHECKINGAsyncGenerator AwaitableCallable GeneratorGenericNoReturnTypeVarUnionoverload)AlreadyUsedErrorremove_tb_frames) ParamSpecfinalArgsTcCs|SN)funcrr3E:\soccer\ml_env\Lib\site-packages\outcome/_impl.pyrsr)ErrorOutcomeMaybeValueacapturecaptureValueTT) covariantResultTzCallable[ArgsT, NoReturn]z ArgsT.argsz ArgsT.kwargsr)sync_fnargskwargsreturncOsdSrrr r!r"rrrr$srzCallable[ArgsT, ResultT]zValue[ResultT] | ErrorcOsdSrrr$rrrr.sc OsPzt||i|WStyJ}zt|d}t|WYd}~Sd}~00dS)zRun ``sync_fn(*args, **kwargs)`` and capture the result. Returns: Either a :class:`Value` or :class:`Error` as appropriate. r Nr BaseExceptionrr)r r!r"excrrrr7s  z$Callable[ArgsT, Awaitable[NoReturn]])async_fnr!r"r#csdSrrr(r!r"rrrrIsrz#Callable[ArgsT, Awaitable[ResultT]]csdSrrr)rrrrRsc sVzt||i|IdHWStyP}zt|d}t|WYd}~Sd}~00dS)zRun ``await async_fn(*args, **kwargs)`` and capture the result. Returns: Either a :class:`Value` or :class:`Error` as appropriate. Nr r%)r(r!r"r'rrrr  F)reprinitslotsc@sxeZdZUdZejddddZded<dddd Ze j d dd d Z e j d ddddZ e j dddddZ dS)ra;An abstract class representing the result of a Python computation. This class has two concrete subclasses: :class:`Value` representing a value, and :class:`Error` representing an exception. In addition to the methods described below, comparison operators on :class:`Value` and :class:`Error` objects (``==``, ``<``, etc.) check that the other object is also a :class:`Value` or :class:`Error` object respectively, and then compare the contained objects. :class:`Outcome` objects are hashable if the contained objects are hashable. F)defaulteqr+bool _unwrappedNoner#cCs|jr tt|dddS)Nr0T)r0robject __setattr__selfrrr_set_unwrappedszOutcome._set_unwrappedrcCsdS)zReturn or raise the contained value or exception. These two lines of code are equivalent:: x = fn(*args) x = outcome.capture(fn, *args).unwrap() Nrr5rrrunwrapszOutcome.unwrap"Generator[ResultT, ValueT, object]rgenr#cCsdS)zSend or throw the contained value or exception into the given generator object. Args: gen: A generator object supporting ``.send()`` and ``.throw()`` methods. Nrr6r;rrrsendsz Outcome.sendAsyncGenerator[ResultT, ValueT]agenr#csdS)zSend or throw the contained value or exception into the given async generator object. Args: agen: An async generator object supporting ``.asend()`` and ``.athrow()`` methods. Nrr6r@rrrasendsz Outcome.asendN)__name__ __module__ __qualname____doc__attribr0__annotations__r7abcabstractmethodr8r=rBrrrrrms   r)frozenr*r,c@s^eZdZUdZeZded<ddddZdddd Z d d d d dZ dd dddZ dS)rzFConcrete :class:`Outcome` subclass representing a regular value. rvaluestrr2cCsd|jdS)NzValue())rMr5rrr__repr__szValue.__repr__cCs||jSr)r7rMr5rrrr8sz Value.unwrapr9rr:cCs|||jSr)r7r=rMr<rrrr=sz Value.sendr>r?cs|||jIdHSr)r7rBrMrArrrrBsz Value.asendN) rCrDrErFrGrHrMrIrPr8r=rBrrrrrs rc@sjeZdZUdZejejedZ de d<ddddZ d dd d Z d d dddZ dd dddZdS)rzIConcrete :class:`Outcome` subclass representing a raised exception. ) validatorr&errorrNr2cCsd|jdS)NzError(rO)rRr5rrrrPszError.__repr__r cCs&||j}z |W~~n~~0dSr)r7rR)r6Zcaptured_errorrrrr8s z Error.unwrapz$Generator[ResultT, NoReturn, object]rr:cCs|||jSr)r7throwrRr<rrrr=sz Error.sendz!AsyncGenerator[ResultT, NoReturn]r?cs|||jIdHSr)r7athrowrRrArrrrBsz Error.asendN)rCrDrErFrGrHZ validatorsZ instance_ofr&rRrIrPr8r=rBrrrrrs  )! __future__rrJtypingrrrrrrr r r r rGZ_utilrrZtyping_extensionsrrr__all__rrrrsABCrrrrrrrrs< 0    8-