U vтТi;у@s8ddlmZddlmZddlmZGddДdeГZdS)щ)┌RLock)┌Optional)┌DisposableBasecs`eZdZdZddЬЗfddДZeedЬddДZeddЬd d ДZe eeГZ ddЬddДZЗZS) ┌SingleAssignmentDisposablea&Single assignment disposable. Represents a disposable resource which only allows a single assignment of its underlying disposable resource. If an underlying disposable resource has already been set, future attempts to set the underlying disposable resource will throw an Error.N)┌returncs"d|_d|_tГ|_tГабdS)zTInitializes a new instance of the SingleAssignmentDisposable class. FN)┌is_disposed┌currentr┌lock┌super┌__init__й┌selfй┌ __class__й·`/opt/alt/python38/lib/python3.8/site-packages/reactivex/disposable/singleassignmentdisposable.pyrsz#SingleAssignmentDisposable.__init__cCs|jS)N)rrrrr┌get_disposablesz)SingleAssignmentDisposable.get_disposable)┌valuerc CsF|jrtdГВ|jП|j}|s&||_W5QRX|jrB|rB|абdS)Nz$Disposable has already been assigned)r┌ Exceptionr r┌dispose)r rZshould_disposerrr┌set_disposables z)SingleAssignmentDisposable.set_disposablec CsBd}|jП|js$d|_|j}d|_W5QRX|dk r>|абdS)zSets the status to disposedNT)r rrr)r ┌oldrrrr*sz"SingleAssignmentDisposable.dispose) ┌__name__┌ __module__┌__qualname__┌__doc__rrrrr┌propertyZ disposabler┌ __classcell__rrrrrs rN)┌ threadingr┌typingrZ reactivex.abcrrrrrr┌s