o [h@sFdZddlZddlmZddlmZmZmZmZm Z ddl m Z m Z ddl mZmZmZddlmZd d lmZeZd Z     ddddddZe     ddddddZe dddddZeedddddZeedddddZeeee dddddZeedddddZdS)z*Handle files using a thread pool executor.N) coroutine)FileIO TextIOBaseBufferedReaderBufferedWriterBufferedRandom)partialsingledispatch)AsyncBufferedIOBaseAsyncBufferedReader AsyncFileIOAsyncTextIOWrapper)AiofilesContextManager)openrTloopexecutorc Cs tt|||||||||| d S)N) mode bufferingencodingerrorsnewlineclosefdopenerrr)r_open) filerrrrrrrrrr!/home/ubuntu/experiments/live_experiments/Pythonexperiments/Otree/venv/lib/python3.10/site-packages/aiofiles/threadpool/__init__.pyrs rc csL|dur t}tt||||||||d } || | EdH} t| || dS)zOpen an asyncio file.N)rrrrrrrr)asyncioZget_event_loopr sync_openZrun_in_executorwrap) r rrrrrrrrrcbfr!r!r"r4s  rcCstd|)NzUnsupported io type: {}.) TypeErrorformatr rrr!r!r"r%Ur%cCt|||dSNrrr*r!r!r"_Zr+r.cCr,r-)r r*r!r!r"r._r+cCr,r-)r r*r!r!r"r.dscCs t|||S)N)r r*r!r!r"r.js )rrNNNTN)__doc__r#typesriorrrrr functoolsrr binaryr r r textrbaserrr$__all__rr%registerr.r!r!r!r"sX