|;3h RddlZddlZddlZddlZddlmZmZddZGddeZy)N)AsyncFileSystem running_asynccBtjfd}|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 c/var/www/html/audio-gradio/venv/lib/python3.12/site-packages/fsspec/implementations/asyn_wrapper.pywrapperzasync_wrapper..wrappers(&&t=d=f====s '%') functoolswraps)r objrs` r async_wrapperr s'"__T>> NcZeZdZdZdZdZ dfd ZedZdZ e dZ 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. ) asyncwrapperrFc | t}t|dd|i||||_nt j |fi||_|jj |_|jy)N asynchronous)rsuper__init__sync_fsfsspec filesystemprotocol_wrap_all_sync_methods)selffsrtarget_protocoltarget_optionsr __class__s r rzAsyncFileSystemWrapper.__init__1sg  (?L =l=f= >DL!,,_OODL --  ##%rc4d|jjS)Nasync_)rfsid)r!s r r(zAsyncFileSystemWrapper.fsidCs ))*++rcvdh}t|jD]}|jds||vrtj|j|}t |t rJt|j|}t|sltj|rt||}t|d||y)zg Wrap all synchronous methods of the underlying filesystem with asynchronous versions. open_)rN) dirr startswithinspectgetattr_static isinstancepropertygetattrcallableriscoroutinefunctionrsetattr)r!excluded_methods method_nameattrmethod async_methods r r z-AsyncFileSystemWrapper._wrap_all_sync_methodsGs#8t||, ?K%%c*k=M.M))$,, 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)r!r r rr% sync_fs_classs r rzSAsyncFileSystemWrapper.wrap_class..GeneratedAsyncFileSystemWrapper.__init__ks'88 )r)__name__ __module__ __qualname__r __classcell__)r%r?s@r GeneratedAsyncFileSystemWrapperr=js  * *rrDAsyncWrapper)r@)clsr?rDs ` r wrap_classz!AsyncFileSystemWrapper.wrap_classYs4" *c * M**+7 3 (0/.r)NNNN) r@rArB__doc__rcachablerr1r(r classmethodrHrC)r%s@r rr!sT /HH  &$,,?$//rrr) rrr.r fsspec.asynrrrrrrr rMs' 60Q/_Q/r