U
vi @ sb d dl mZmZ d dlmZ d dlmZmZ ddlm Z m Z edddZ
G d d
d
e j e
Z d S ) )OptionalTypeVar)SingleAssignmentDisposable)
default_errornoop )abctyping_T_inT)
contravariantc @ s e Zd Zdeeje eej eej ddddZ eddddZ
e ddd d
Z dd d d
Z
ejddddZeedZdd ddZe edddZdS )AutoDetachObserverN)on_nexton_error on_completedreturnc C s0 |pt | _|pt| _|pt | _t | _d| _d S )NF)r _on_nextr _on_error
_on_completedr
_subscription
is_stopped)selfr
r r r V/opt/alt/python38/lib/python3.8/site-packages/reactivex/observer/autodetachobserver.py__init__ s
zAutoDetachObserver.__init__)valuer c C s | j r
d S | | d S N)r r r r r r r r
s zAutoDetachObserver.on_next)errorr c C s. | j r
d S d| _ z| | W 5 | X d S NT)r disposer )r r r r r r s zAutoDetachObserver.on_error)r c C s, | j r
d S d| _ z | W 5 | X d S r )r r r r r r r r ( s z AutoDetachObserver.on_completedc C s || j _d S r )r Z
disposabler r r r set_disposable2 s z!AutoDetachObserver.set_disposable)fsetc C s d| _ | j d S r )r r r r r r r r 7 s zAutoDetachObserver.dispose)exnr c C s | j r
dS d| _ | | dS )NFT)r r )r r# r r r fail; s
zAutoDetachObserver.fail)NNN)__name__
__module__ __qualname__r r ZOnNextr
ZOnErrorZ OnCompletedr r
Exceptionr r r ZDisposableBaser! propertyZ subscriptionr boolr$ r r r r r s
r N)
r r r Zreactivex.disposabler Zreactivex.internalr r r r
Z ObserverBaser r r r r s