U ~fh@sddlmZddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z ddlZddlmZmZerzddlmZmZedZndd Zd d d d ddgZe dddZe dZe dddd dddZe dddddddZdddddddZe dddd dddZe d ddddd!dZd ddddd"dZejd#d#dd$Gd%d d eje eZeejdd#dd&Gd'd d eee eZeejdd#dd&Gd(d d ee Ze eeefZ dS))) annotationsN) TYPE_CHECKINGAsyncGenerator AwaitableCallable GeneratorGenericNoReturnTypeVarUnionoverload)AlreadyUsedErrorremove_tb_frames) ParamSpecfinalArgsTcCs|SN)funcrr1/tmp/pip-unpacked-wheel-58dcm9s0/outcome/_impl.pyrsrErrorOutcomeMaybeValueacapturecaptureValueTT) covariantResultTzCallable[ArgsT, NoReturn]z ArgsT.argsz ArgsT.kwargs)sync_fnargskwargsreturncOsdSrrr r!r"rrrr$szCallable[ArgsT, ResultT]zValue[ResultT] | ErrorcOsdSrrr$rrrr.sc OsNzt|||WStk rH}zt|d}t|WYSd}~XYnXdS)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"rrrrIsz#Callable[ArgsT, Awaitable[ResultT]]csdSrrr)rrrrRsc sTzt|||IdHWStk rN}zt|d}t|WYSd}~XYnXdS)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   )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 c@sjeZdZUdZejejedZ de d<ddddZ d dd d Z d d dddZ dd dddZdS)rzIConcrete :class:`Outcome` subclass representing a raised exception. )Z validatorr&errorrNr2cCsd|jdS)NzError(rO)rQr5rrrrPszError.__repr__r cCs"||j}z|W5~~XdSr)r7rQ)r6Zcaptured_errorrrrr8s z Error.unwrapz$Generator[ResultT, NoReturn, object]rr:cCs|||jSr)r7throwrQr<rrrr=sz Error.sendz!AsyncGenerator[ResultT, NoReturn]r?cs|||jIdHSr)r7athrowrQrArrrrBsz Error.asendN)rCrDrErFrGrHZ validatorsZ instance_ofr&rQrIrPr8r=rBrrrrrs  )! __future__rrJtypingrrrrrrr r r r rGZ_utilrrZtyping_extensionsrrr__all__rrrrsABCrrrrrrrrs< 0    8-