a

X>h.�@srdZd
dl
mZ
d
dlmZ
gd�
Zdd�Zdd�Zd	d
�Zdd�Z	ddd�
Z
dd�Zdd�Zdd�Z
dd�Zd
S)zFunctional utilities.�
)
�Thenable�
�promise)�
maybe_promise�ensure_promise�ppartial�preplace�
ready_promise�starpromise�	transform�wrapc

Cs|rt|t
�st|�
S|S)
zBReturn None if p is undefined, otherwise make sure it's a promise.)�
isinstancerr�
�
p�r�7/usr/local/lib/python3.9/site-packages/vine/funtools.pyrs



rc

Cs|d
urt�St
|�
S)zeEnsure p is a promise.

    If p is not a promise, a new promise is created with p' as callback.
    N)rrrrrrrs

rc
Os,t|�
}|
r|
|j
|_
|r(|j�|�

|S)
z-Create/modify promise with partial arguments.)r�args�kwargs�update)rrrrrrrs




rc
s��
�fd
d�}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��i�
�
�
S�
Nr)�
_�__�rrrrr�	_replacer/s
zpreplace.<locals>._replacerr)rrrrrrrr(srNc
Gst|�
}||
�
|S)
z)Create promise that is already fulfilled.)
r)�callbackrrrrrr	4s

r	c
Ost||
|�S)
z%Create promise, using star arguments.r)Zfunrrrrrr
;sr
cOs.t|
�
}
t
t||
||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_rZfilter_args�
filter_kwargs�
Prrrr@s


rcCs@z|||f
i|�
�
}Wnty2


|
�
�
Yn
0|
|�
SdSr)�	Exceptionr)rrrr�retrrrr\s




rc
s�f
d
d�}
|
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.
    cs:t|�
d
kr(t
|dt�r(|d���
S�|i|
�
�
SdS)Nr
�)�lenr
rr)rrrrr�on_callks

zwrap.<locals>.on_callr)rr%rrrresr)
N)�__doc__ZabstractrZpromisesr�__all__rrrrr	r
rrrrrrr�<module>
s