U
vâ’iV ã @ sx d dl mZmZmZ d dlmZmZm Z d dlmZ d
eded f ee j eef eg ee f dœdd „Z
d gZ dS ) é )ÚAnyÚCallableÚOptional)Ú
ObservableÚabcÚtyping)Ú
DisposableN.).N)ÚfuncÚmapperÚreturnc s t tt dœ‡ ‡fdd„ }|S )a Converts a callback function to an observable sequence.
Args:
func: Function with a callback as the last argument to
convert to an Observable sequence.
mapper: [Optional] A mapper which takes the arguments
from the callback to produce a single item to yield on next.
Returns:
A function, when executed with the required arguments minus
the callback, produces an Observable sequence with a single value of
the arguments to the callback as a list.
©Úargsr c s: t | ƒ‰ dtjt ttj tjdœ‡ ‡‡fdd„
}t|ƒS )N)ÚobserverÚ schedulerr c s. t d dœ‡‡ fdd„ }ˆ |¡ ˆˆŽ tƒ S )Nr c
s† t | ƒ}ˆ rXz ˆ | ƒ}W n2 tk
rJ } zˆ |¡ W Y ¢d S d }~X Y nX ˆ |¡ n*t|ƒdkrpˆj|Ž n
ˆ |¡ ˆ ¡ d S )Né )ÚlistÚ ExceptionZon_errorZon_nextÚlenZ on_completed)r
ÚresultsÚerr)r
r © úR/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/fromcallback.pyÚhandler s
zDfrom_callback_..function..subscribe..handler)r Úappendr )r r r )Ú argumentsr r
)r r Ú subscribe s
z3from_callback_..function..subscribe)N)r r Z ObserverBaser r Z
SchedulerBaseZDisposableBaser )r
r ©r r
)r r Úfunction s þýz from_callback_..function)r r )r r
r r r r Úfrom_callback_ s r )N) r r r r Z reactivexr r Zreactivex.disposabler ZMapperr Ú__all__r r r r Ú s þý 4