U ‰d- ã@s~dZddlmZddlmZdddddd d d gZd d„Zd d„Zdd„Zdd„Z ddd„Z dd „Z dd „Z dd„Z dd „ZdS)zFunctional utilities.é)ÚThenable©ÚpromiseÚ maybe_promiseÚensure_promiseÚppartialÚpreplaceÚ ready_promiseÚ starpromiseÚ transformÚwrapcCs|rt|tƒst|ƒS|S)zAReturn None if p is unefined, otherwise make sure it's a promise.)Ú isinstancerr©Úp©rú1/tmp/pip-unpacked-wheel-1j4yz0ik/vine/funtools.pyr s cCs|dkrtƒSt|ƒS)zeEnsure p is a promise. If p is not a promise, a new promise is created with p' as callback. N)rrrrrrrscOs,t|ƒ}|r||j|_|r(|j |¡|S)z-Create/modify promise with partial arguments.)rÚargsÚkwargsÚupdate)rrrrrrrs   cs‡‡‡fdd„}t|ƒS)z¸Replace promise arguments. This will force the promise to disregard any arguments the promise is fulfilled with, and to be called with the provided arguments instead. cs ˆˆˆŽS©Nr)Ú_Ú__©rrrrrÚ _replacer/szpreplace.._replacerr)rrrrrrrr(sNcGst|ƒ}||Ž|S)z)Create promise that is already fulfilled.)r)Úcallbackrrrrrr 4scOs t|||ƒS)z%Create promise, using star arguments.r)Zfunrrrrrr ;scOs.t|ƒ}tt||||fƒ}| tƒ|j¡|S)a?Filter final argument to a promise. E.g. to coerce callback argument to :class:`int`:: transform(int, callback) or a more complex example extracting something from a dict and coercing the value to :class:`float`: .. code-block:: python def filter_key_value(key, filter_, mapping): return filter_(mapping[key]) def get_page_expires(self, url, callback=None): return self.request( 'GET', url, callback=transform(get_key, callback, 'PageExpireValue', int), ) )rrÚ _transbackÚthenÚthrow)Úfilter_rZ filter_argsZ filter_kwargsÚPrrrr @scCs>z|||f|Ž}Wntk r0| ¡Yn X||ƒSdSr)Ú Exceptionr)rrrrÚretrrrr\s rcs‡fdd„}|S)zžWrap promise. This wraps the promise such that if the promise is called with a promise as argument, we attach ourselves to that promise instead. cs6t|ƒdkr(t|dtƒr(|d ˆ¡Sˆ||ŽSdS)Nré)Úlenr rr)rrrrrÚon_callkszwrap..on_callr)rr$rrrr es )N)Ú__doc__ZabstractrZpromisesrÚ__all__rrrrr r r rr rrrrÚs(  ý