U /e @s(ddlmZddlZddlmZmZmZmZddlm Z ddl m Z ddl m Z ddlmZddlmZdd lmZmZmZmZed Zed Zed Zerdd lmZmZedZGddde ZejZGdddeeefZdddddZ dddddZ!dd ddddZ"dddd d!Z#dS)") annotationsN)CallableIterableIteratorMapping)contextmanager)Enumwraps)chain)MutableMapping) TYPE_CHECKINGAnyTypeVarcastTKTVT) ParamSpecSelfPc@seZdZdZdS) NoDefaultN)__name__ __module__ __qualname__ nodefaultrr//tmp/pip-unpacked-wheel-z3s6s24u/zict/common.pyrsrc@seZdZUdZded<ddddZddd d Zddd d d Zd+ddddddZdddddZ dddddZ ddddZ dddd Z d!dd"d#d$Z ddd%d&Zed'dd(d)Zd*S),ZictBasezBase class for zict mappingszthreading.RLocklockNone)returncCst|_dSN) threadingRLockrselfrrr__init__$szZictBase.__init__zdict[str, Any]cCs|j}|d=|S)Nr)__dict__copyr&staterrr __getstate__'s zZictBase.__getstate__)r+r!cCs||_t|_dSr")r(r#r$rr*rrr __setstate__,szZictBase.__setstate__rz)Mapping[KT, VT] | Iterable[tuple[KT, VT]]r)otherkwargsr!cKs.t|dr|}t||}||dS)Nitems)hasattrr0r _do_update)r&r.r/rrrupdate0s zZictBase.updatezIterable[tuple[KT, VT]])r0r!cCs|D]\}}|||<qdSr"r)r&r0kvrrrr2;s zZictBase._do_updater)keyr!cCst||dS)zvFlush *key* if possible. Not the same as ``m.pop(key, None)``, as it doesn't trigger ``__getitem__``. N)discard)r&r6rrrr7@szZictBase.discardcCsdS)z0Release any system resources held by this objectNrr%rrrcloseFszZictBase.closercCs|Sr"rr%rrr __enter__IszZictBase.__enter__r)argsr!cGs |dSr"r8)r&r:rrr__exit__LszZictBase.__exit__cCs |dSr"r;r%rrr__del__OszZictBase.__del__zIterator[None]ccs&|jz dVW5|jXdS)zkTo be used in a method decorated by ``@locked``. Temporarily releases the mapping's RLock. N)rreleaseacquirer%rrrunlockRs  zZictBase.unlockN)r)rrr__doc____annotations__r'r,r-r3r2r7r8r9r<r=rr@rrrrrs  rrr )zr!cGs |D]}t|dr|qdS)zClose *z* if possible.r8N)r1r8rCZzirrrr8^s r8cGs |D]}t|dr|qdS)zFlush *z* if possible.flushN)r1rErDrrrrEes rEzMutableMapping[KT, VT])mr6r!cCs$z ||=Wntk rYnXdS)znFlush *key* if possible. Not the same as ``m.pop(key, None)``, as it doesn't trigger ``__getitem__``. N)KeyError)rFr6rrrr7ls r7zCallable[P, VT])funcr!cs"tddddfdd }|S)z~Decorator for a method of ZictBase, which wraps the whole method in a instance-specific (but not key-specific) rlock. zP.argszP.kwargsr)r:r/r!c s6tt|d}|j||W5QRSQRXdS)Nr)rrr)r:r/r&rHrrwrapper{szlocked..wrapperr )rHrJrrIrlockedvsrK)$ __future__rr#collections.abcrrrr contextlibrenumr functoolsr itertoolsr typingr r rrrrrrZtyping_extensionsrrrrrrr8rEr7rKrrrrs*      ?