wg0 FddlZddlZddlZddlmZddZGddeZy)N)AsyncFileSystemcBtjfd}|S)aF Wraps a synchronous function to make it awaitable. Parameters ---------- func : callable The synchronous function to wrap. obj : object, optional The instance to bind the function to, if applicable. Returns ------- coroutine An awaitable version of the function. cRKtjg|i|d{S7wN)asyncio to_thread)argskwargsfuncs h/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/fsspec/implementations/asyn_wrapper.pywrapperzasync_wrapper..wrappers(&&t=d=f====s '%') functoolswraps)r objr s` r async_wrapperrs'"__T>> NcHeZdZdZfdZedZdZedZ xZ S)AsyncFileSystemWrapperaX A wrapper class to convert a synchronous filesystem into an asynchronous one. This class takes an existing synchronous filesystem implementation and wraps all its methods to provide an asynchronous interface. Parameters ---------- sync_fs : AbstractFileSystem The synchronous filesystem instance to wrap. ct||i|d|_||_|jj|_|j y)NT)super__init__ asynchronoussync_fsprotocol_wrap_all_sync_methods)selfrr r __class__s r rzAsyncFileSystemWrapper.__init__-sA $)&)   --  ##%rc4d|jjS)Nasync_)rfsid)rs r r zAsyncFileSystemWrapper.fsid4s ))*++rcht|jD]}|jdrtj|j|}t |t rFt|j|}t|shtj|r~t||}t|d||y)zg Wrap all synchronous methods of the underlying filesystem with asynchronous versions. _)rN) dirr startswithinspectgetattr_static isinstancepropertygetattrcallableriscoroutinefunctionrsetattr)r method_nameattrmethod async_methods r rz-AsyncFileSystemWrapper._wrap_all_sync_methods8st||, ?K%%c*))$,, DD$)T\\;7F(C(CF(K,V> +/> ?rcLGfdd|}djd|_|S)a Create a new class that can be used to instantiate an AsyncFileSystemWrapper with lazy instantiation of the underlying synchronous filesystem. Parameters ---------- sync_fs_class : type The class of the synchronous filesystem to wrap. Returns ------- type A new class that wraps the provided synchronous filesystem class. c"eZdZfdZxZS)JAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrapperc4|i|}t||yr)rr)rr r rr sync_fs_classs r rzSAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrapper.__init__[s'88 )r)__name__ __module__ __qualname__r __classcell__)rr5s@r GeneratedAsyncFileSystemWrapperr3Zs  * *rr:AsyncWrapper)r6)clsr5r:s ` r wrap_classz!AsyncFileSystemWrapper.wrap_classIs4" *c * M**+7 3 (0/.r) r6r7r8__doc__rr(r r classmethodr>r9)rs@r rr s: &,,?"//rrr)rrr% fsspec.asynrrrrr rCs$'0B/_B/r