U
vâ’i; ã @ sn d dl mZmZmZ d dlZd dlmZ d dlmZ edƒZd ee eee gee f dœdd„Z
dgZ dS )
é )ÚCallableÚOptionalÚTypeVarN)Ú
Observable)ÚinfiniteÚ_T)Ú retry_countÚreturnc s8 | dkrt ƒ ‰ nt| ƒ‰ tt tt dœ‡ fdd„ }|S )a Repeats the source observable sequence the specified number of
times or until it successfully terminates. If the retry count is
not specified, it retries indefinitely.
Examples:
>>> retried = retry()
>>> retried = retry(42)
Args:
retry_count: [Optional] Number of times to retry the sequence.
If not provided, retry the sequence indefinitely.
Returns:
An observable sequence producing the elements of the given
sequence repeatedly until it terminates successfully.
N)Úsourcer c s t ‡ fdd„ˆD ƒ¡S )Nc 3 s | ]
}ˆ V qd S )N© )Ú.0Ú_©r
r úK/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_retry.pyÚ $ s z(retry_..retry..)Ú reactivexZcatch_with_iterabler ©Úgenr r Úretry# s zretry_..retry)r Úranger r )r r r r r Úretry_
s
r )N) Útypingr r r r r Zreactivex.internal.utilsr r Úintr Ú__all__r r r r Ú s ÿþ