U
vâ’io ã
@ sH d dl mZ d dlmZmZmZmZ edƒZedƒZedƒZ edƒZ
edƒZ edƒZ ed ƒZ
ed
ƒZed ƒZed ƒZeeegef eegef d
œdd„ƒZeeegef eege f eege f dœdd„ƒZeeegef eege f ee ge
f eege
f dœdd„ƒZeeegef eege f ee ge
f ee
ge f eege f dœdd„ƒZeeegef eege f ee ge
f ee
ge f ee ge f eege f dœdd„ƒZeeegef eege f ee ge
f ee
ge f ee ge f ee ge
f eege
f dœdd„ƒZeegef eegef dœdd„Zeeed œd d „ƒZeeeegef ed œd d „ƒZeeeegef eege f e d!œd"d „ƒZeeeegef eege f ee ge
f e
d#œd$d „ƒZeeeegef eege f ee ge
f ee
ge f e d%œd&d „ƒZeeeegef eege f ee ge
f ee
ge f ee ge f e d'œd(d „ƒZeeeegef eege f ee ge
f ee
ge f ee ge f ee ge
f e
d)œd*d „ƒZeeeegef eege f ee ge
f ee
ge f ee ge f ee ge
f ee
gef ed+œ d,d „ƒZeeeegef eege f ee ge
f ee
ge f ee ge f ee ge
f ee
gef eegef ed-œ
d.d „ƒZeeeegef eege f ee ge
f ee
ge f ee ge f ee ge
f ee
gef eegef eegef ed/œ d0d „ƒZeeegef ed1œd2d „Zd dgZd3S )4é ©Úreduce)ÚAnyÚCallableÚTypeVarÚoverloadÚ_AÚ_BÚ_CÚ_DÚ_EÚ_FÚ_GÚ_HÚ_TÚ_J)Ú__op1Úreturnc C s d S ©N© )r r r ú?/opt/alt/python38/lib/python3.8/site-packages/reactivex/pipe.pyÚcompose s r )r Ú__op2r c C s d S r r )r r r r r r s )r r Ú__op3r c C s d S r r )r r r r r r r s )r r r Ú__op4r c C s d S r r )r r r r r r r r " s )r r r r Ú__op5r c C s d S r r )r r r r r r r r r + s )r r r r r Ú__op6r c C s d S r r )r r r r r r r r r r 5 s )Ú operatorsr c s t t dœ‡ fdd„ }|S )aÚ Compose multiple operators left to right.
Composes zero or more operators into a functional composition. The
operators are composed to left to right. A composition of zero
operators gives back the source.
Examples:
>>> pipe()(source) == source
>>> pipe(f)(source) == f(source)
>>> pipe(f, g)(source) == g(f(source))
>>> pipe(f, g, h)(source) == h(g(f(source)))
...
Returns:
The composed observable.
)Úsourcer c s t dd„ ˆ | ƒS )Nc S s || ƒS r r )ZobsÚopr r r ÚS ó z+compose.._compose..r )r ©r r r Ú_composeR s zcompose.._compose)r )r r# r r" r r @ s )Ú__valuer c C s d S r r )r$ r r r ÚpipeX s r% )r$ Ú__fn1r c C s d S r r )r$ r& r r r r% \ s )r$ r& Ú__fn2r c C s d S r r )r$ r& r' r r r r% ` s )r$ r& r' Ú__fn3r c C s d S r r )r$ r& r' r( r r r r% h s )r$ r& r' r( Ú__fn4r c C s d S r r )r$ r& r' r( r) r r r r% q s )r$ r& r' r( r) Ú__fn5r c C s d S r r )r$ r& r' r( r) r* r r r r% { s )r$ r& r' r( r) r* Ú__fn6r c C s d S r r )r$ r& r' r( r) r* r+ r r r r% † s ) r$ r& r' r( r) r* r+ Ú__fn7r c C s d S r r )r$ r& r' r( r) r* r+ r, r r r r% ’ s
)
r$ r& r' r( r) r* r+ r, Ú__fn8r c C s d S r r ) r$ r& r' r( r) r* r+ r, r- r r r r% Ÿ s ) r$ r& r' r( r) r* r+ r, r- Ú__fn9r c
C s d S r r )
r$ r& r' r( r) r* r+ r, r- r. r r r r% s )r$ Úfnsr c G s t |Ž | ƒS )züFunctional pipe (`|>`)
Allows the use of function argument on the left side of the
function.
Example:
>>> pipe(x, fn) == __fn(x) # Same as x |> fn
>>> pipe(x, fn, gn) == gn(fn(x)) # Same as x |> fn |> gn
...
)r )r$ r/ r r r r% ¼ s N)Ú functoolsr Útypingr r r r r r r
r r r
r r r r r r% Ú__all__r r r r Ú s & þ ü û ú ù
$ ü û ú ù
ø ÷ ö
õ