U
viC @ s^ d dl mZmZmZ d dlmZmZmZ edZeeee gee f dddZ dgZ
dS ) )CallableOptionalTypeVar) Notification
Observableabc_T)returnc C s t tt t t ddd} | S )N)sourcer c s* dt jt tt j d fdd
}t|S )a= Partially applied dematerialize operator.
Dematerializes the explicit notification values of an
observable sequence as implicit notifications.
Returns:
An observable sequence exhibiting the behavior
corresponding to the source sequence's notification values.
N)observer schedulerc s. t t d d fdd }j| j j|dS )N)valuer c s
| S )N)accept)r
r S/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_dematerialize.pyon_next s zIdematerialize_..dematerialize..subscribe..on_next)r )r r subscribeZon_errorZ on_completed)r r r r
r r r s z8dematerialize_..dematerialize..subscribe)N)r Z ObserverBaser r Z
SchedulerBaser )r
r r r r
dematerialize s
z%dematerialize_..dematerialize)r r r )r r r r dematerialize_ s r N) typingr r r Z reactivexr r r r r __all__r r r r s $