U
vi @ s d dl mZmZmZmZ d dlmZmZ d dlm Z edZ
d e
eej ee
dddZ d
eg e
f eej ee
d d
d Z
dd gZdS ) )AnyCallableOptionalTypeVar)
Observableabc)CurrentThreadScheduler_TN)value schedulerreturnc s0 dt jt tt j t jd fdd
}t|S )a Returns an observable sequence that contains a single element,
using the specified scheduler to send out observer messages.
There is an alias called 'just'.
Examples:
>>> res = return(42)
>>> res = return(42, rx.Scheduler.timeout)
Args:
value: Single element in the resulting observable sequence.
Returns:
An observable sequence containing the single specified
element.
Nobserver
scheduler_r c s6 p|pt }dtjtd d fdd
}||S )N)r stater c s d S N)on_next on_completed)r r )r r
Q/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/returnvalue.pyaction! s
z0return_value_..subscribe..action)Nr Z singletonr
SchedulerBaser Zscheduler r Z
_schedulerr r r
r r subscribe s z return_value_..subscribe)Nr Z ObserverBaser r r ZDisposableBaser )r
r r r r r
return_value_ s r )supplierr r c s0 dt jt tt j t jd fdd
}t|S )Nr
c s6 p|pt }dtjtd d fdd
}||S )N)___r c
sJ z W n, tk
rD } z | W 5 d }~X Y nX d S r )r r ExceptionZon_error)r r! e)r r r r r 2 s
z1from_callable_..subscribe..action)Nr r r r r r r - s z!from_callable_..subscribe)Nr )r r r r r$ r from_callable_* s r% )N)N)typingr r r r Z reactivexr r Zreactivex.schedulerr r r r r% __all__r r r r s "