U
vi @ sf d dl Z d dlmZmZmZ d dlmZ d dlmZ ddl m
Z
e Z edZ e
e e dd d
Z
dS ) N)OptionalTypeVarcast) SequenceContainsNoElementsError)NewThreadScheduler )
Observable_T)sourcereturnc s dt dttdd tddfdd }tdd fdd }dd fd
d }| j|||td s qrrttstS )
a` Run source synchronously.
Subscribes to the observable source. Then blocks and waits for the
observable source to either complete or error. Returns the
last value emitted, or throws exception if any error occured.
Examples:
>>> result = run(source)
Args:
source: Observable source to run.
Raises:
SequenceContainsNoElementsError: if observable completes
(on_completed) without any values being emitted.
Exception: raises exception if any error (on_error) occured.
Returns:
The last element emitted from the observable.
NF)valuer c s | d d S NT )r )
has_resultresultr >/opt/alt/python38/lib/python3.8/site-packages/reactivex/run.pyon_next) s zrun..on_next)errorr c s | d d S r
set)r )done exceptionlatchr r on_error. s zrun..on_error)r c s d d S r
r r )r r r r on_completed5 s zrun..on_completed) scheduler) threadingEventr r Exception subscriber waitr )r
r r r r )r r r r r r run s
r! )r typingr r r Z reactivex.internal.exceptionsr Zreactivex.schedulerr Z
observabler r r r! r r r r s