U
vi
@ s d dl Z d dl mZ d dlmZmZmZmZ d dlmZm Z d dl
m Z edZ d eeg df ee j
eee gdf dd d
Zd
gZdS ) N)Future)CallableOptionalTypeVarcast)
Observableabc) SequenceContainsNoElementsError_T
Future[_T]) future_ctor schedulerreturnc s2 | p t j}| tt dd fdd }|S )Nr )sourcer c sl dt tdtdfdd }tdfdd }fd d
}| j|||d fd d
S )a. Converts an existing observable sequence to a Future.
If the observable emits a single item, then this item is set as the
result of the future. If the observable emits a sequence of items, then
the last emitted item is set as the result of the future.
Example:
future = reactivex.return_value(42).pipe(ops.to_future(asyncio.Future))
Args:
future_ctor: [Optional] The constructor of the future.
Returns:
A future with the last value from the observable sequence.
FNvaluec s | d d S )NT r ) has_value
last_valuer N/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_tofuture.pyon_next( s z.to_future_..to_future..on_nexterrc s s | d S N) cancelled
set_exceptionr )futurer r on_error. s z/to_future_..to_future..on_errorc s, s$r n t d d S r )r
set_resultr r r )r r r r r on_completed2 s
z3to_future_..to_future..on_completed)r
c s S r )Zdispose)_)disr r < z/to_future_..to_future..)r r
Exception subscribeadd_done_callback)r r r r r r
)r! r r r to_future s
z to_future_..to_future)asyncioget_event_loop
create_futurer r
)r r
Z future_ctor_r( r r' r
to_future_ s
,r, )NN)r) r typingr r r r Z reactivexr r Z reactivex.internal.exceptionsr r
Z
SchedulerBaser, __all__r r r r s 8