U
vio @ s~ d dl mZmZmZmZ d dlmZmZm Z d dlm Z d dl
m Z edZ e e j
e e je e f ee dddZdgZd S )
)AnyOptionalTypeVarcast)
Observableabctyping) MultipleAssignmentDisposable)CurrentThreadScheduler_TState)
initial_state conditioniteratereturnc s2 dt jt tt j t jd fdd
}t|S )N)observer schedulerr c sP |p
t }dt dtjtd d fdd
| _S )NT)r state1r c
s d}t td }z&rdn}|r2}W n2 tk
rf } z| W Y d S d }~X Y nX |r| | _n d S )NF)r r ExceptionZon_errorZon_nextschedule
disposableZ on_completed)r r Z
has_resultresult exception)actionr
firstr madr state N/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/generate.pyr s
z,generate_..subscribe..action)N)r
Z singletonr r
SchedulerBaser r r )r r r
r r )r r r r r r subscribe s & z generate_..subscribe)N)r Z ObserverBaser r r ZDisposableBaser )r r
r r r r r generate_
s 'r! N)r r r r r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr
r Z PredicateZMapperr! __all__r r r r s /