o Rh@s|ddlmZddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z ddlZddlmZmZer=ddlmZmZedZndd Zgd Ze d d d Ze dZe d,ddZe d-ddZd-ddZe d.dd Ze d/d"d Zd/d#d Zejd$d$d d%Gd&d'd'eje eZeejd d$d d(Gd)d*d*eee eZeejd d$d d(Gd+ddee Ze eeefZ dS)0) annotationsN) TYPE_CHECKINGAsyncGenerator AwaitableCallable GeneratorGenericNoReturnTypeVarUnionoverload)AlreadyUsedErrorremove_tb_frames) ParamSpecfinalArgsTcCs|SN)funcrrO/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/outcome/_impl.pyrsr)ErrorOutcomeMaybeValueacapturecaptureValueTT) covariantResultTsync_fnCallable[ArgsT, NoReturn]args ArgsT.argskwargs ArgsT.kwargsreturnrcOdSrrr r"r$rrrr$srCallable[ArgsT, ResultT]Value[ResultT] | ErrorcOr'rrr(rrrr.sc OsLz t||i|WSty%}zt|d}t|WYd}~Sd}~ww)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  async_fn$Callable[ArgsT, Awaitable[NoReturn]]cdSrrr.r"r$rrrrIr#Callable[ArgsT, Awaitable[ResultT]]cr0rrr1rrrrRr2c sTz t||i|IdHWSty)}zt|d}t|WYd}~Sd}~ww)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@sdeZdZUdZejddddZded<ddd Ze j dd d Z e j dddZ e j dddZ 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)defaulteqr5bool _unwrappedr&NonecCs|jrtt|dddS)Nr:T)r:robject __setattr__selfrrr_set_unwrappedszOutcome._set_unwrappedrcCdS)zReturn or raise the contained value or exception. These two lines of code are equivalent:: x = fn(*args) x = outcome.capture(fn, *args).unwrap() Nrr>rrrunwrapzOutcome.unwrapgen"Generator[ResultT, ValueT, object]rcCrA)zSend or throw the contained value or exception into the given generator object. Args: gen: A generator object supporting ``.send()`` and ``.throw()`` methods. Nrr?rDrrrsendrCz Outcome.sendagenAsyncGenerator[ResultT, ValueT]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. Nrr?rHrrrasendsz Outcome.asendN)r&r;r&rrDrEr&rrHrIr&r)__name__ __module__ __qualname____doc__attribr:__annotations__r@abcabstractmethodrBrGrKrrrrrms     r)frozenr4r6c@sLeZdZUdZeZded< dddZddd Z dd dZ dddZ dS)rzFConcrete :class:`Outcome` subclass representing a regular value. rvaluer&strcCd|jdS)NzValue())rYr>rrr__repr__zValue.__repr__cCs||jSr)r@rYr>rrrrBsz Value.unwraprDrErcC|||jSr)r@rGrYrFrrrrG z Value.sendrHrIc|||jIdHSr)r@rKrYrJrrrrKz Value.asendNr&rZrLrMrN) rOrPrQrRrSrTrYrUr]rBrGrKrrrrrs    rc@sXeZdZUdZejejedZ de d< dddZ dd d Z dddZ dddZdS)rzIConcrete :class:`Outcome` subclass representing a raised exception. ) validatorr,errorr&rZcCr[)NzError(r\)rer>rrrr]r^zError.__repr__r cCs||j}z|~~wr)r@re)r?captured_errorrrrrBs z Error.unwraprD$Generator[ResultT, NoReturn, object]rcCr_r)r@throwrerFrrrrGr`z Error.sendrH!AsyncGenerator[ResultT, NoReturn]crar)r@athrowrerJrrrrKrbz Error.asendNrc)r&r )rDrgr&r)rHrir&r)rOrPrQrRrSrT validators instance_ofr,rerUr]rBrGrKrrrrrs     )r r!r"r#r$r%r&r)r r)r"r#r$r%r&r*)r.r/r"r#r$r%r&r)r.r3r"r#r$r%r&r*)! __future__rrVtypingrrrrrrr r r r rS_utilrrtyping_extensionsrrr__all__rrrrsABCrrrrrrrrs> 0         8-