}tfUddlmZddlZddlZddlZddlmZddlmZddl m Z gdZ ejZ ded<Gd d ZGd d Zy) ) annotationsN)deque)Iterator)Signal) FileContentsVirtualFileContents_VIRTUAL_FILESz5weakref.WeakValueDictionary[str, VirtualFileContents]r cjeZdZdZeeZdddZed dZ e jd dZ d dZ y) raStores text file contents in memory and emits a signal when it changes. Calling `str(obj)` on this object will always return the current contents. Parameters ---------- contents : str, optional The initial contents of the file (default: "") c||_yN _contents)selfcontentss b/var/www/html/software/conda/envs/higlass/lib/python3.12/site-packages/anywidget/_file_contents.py__init__zVirtualFileContents.__init__s !c|jSr r rs rrzVirtualFileContents.contents"s ~~rcH||_|jj|yr )rchangedemit)rvalues rrzVirtualFileContents.contents&s % rc|jSr )rrs r__str__zVirtualFileContents.__str__+s }}rN))rstrreturnr)rrrNone) __name__ __module__ __qualname____doc__rrrrpropertyrsetterrrrrrsHSkG"__!!rrcXeZdZdZeeZeZdd dZd dZ d dZ d dZ d dZ y) raObject that watches for file changes and emits a signal when it changes. Calling `str(obj)` on this object will always return the current contents of the file (as long as the thread is running). Parameters ---------- path : str | pathlib.Path The file to read and watch for content changes start_thread : bool, optional Whether to start watching for changes in a separate thread (default: `True`) c.tj|jj|_|jj s t dd|_tj|_ d|_ |r|jyy)Nz!File does not exist: {self._path}) pathlibPath expanduserabsolute_pathis_file ValueErrorr threadingEvent _stop_event_background_threadwatch_in_thread)rpath start_threads rrzFileContents.__init__@sr\\$'224==? zz!!#@A A%)$??,;?   " rcjyjjtjfdd_jj y)zEWatch for file changes (and emitting signals) from a separate thread.Nc:tjdS)Nr)maxlen)rwatchrsrz.FileContents.watch_in_thread..Ss5a8rT)targetdaemon)r4r3clearr1Threadstartrs`rr5zFileContents.watch_in_threadJsS  " " .   "+"2"29 #  %%'rc|jy|jj|jjd|_y)z.Stops an actively running thread if it exists.N)r4r3setjoinrs r stop_threadzFileContents.stop_threadXs=  " " *   $$&"&rc#K ddlm}m}||j|j D]}|D]\}}||j k(r|j jy||jk(s||jk(sQd|_ |jjt|||fy#t$r}td|d}~wwxYww)a Watch for file changes and emit changed/deleted signal events. Blocks indefinitely. Returns ------- changes : Iterator[tuple[int, str]] An iterator that yields any time the file changes until the file is deleted. r)Changer;zkwatchfiles is required to watch for file changes during development. Install with `pip install watchfiles`.N) stop_event) watchfilesrGr; ImportErrorr.r3deletedrmodifiedaddedrrr)rrGr;excchangeschanger6s rr;zFileContents.watch`s  0TZZD4D4DE G '  V^^+LL%%'V__,&,,0F%)DNLL%%c$i0!4.(    9  s.CB7A3C7C7 C C  CCct|j!|jjd|_|jS)Nzutf-8)encoding)rr. read_textrs rrzFileContents.__str__~s/ >> !!ZZ1171CDN~~rN)T)r6zstr | pathlib.Pathr7bool)rr )rzIterator[tuple[int, str]]r) r!r"r#r$rrrrKrr5rEr;rr'rrrr/s2 SkGhG# ('<rr) __future__rr*r1weakref collectionsrtypingrpsygnalr__all__WeakValueDictionaryr __annotations__rrr'rrr]sR" C G!E :RRr