| from ..base import AsyncBase, AsyncIndirectBase |
| from .utils import delegate_to_executor, proxy_method_directly, proxy_property_directly |
|
|
|
|
| @delegate_to_executor( |
| "close", |
| "flush", |
| "isatty", |
| "read", |
| "read1", |
| "readinto", |
| "readline", |
| "readlines", |
| "seek", |
| "seekable", |
| "tell", |
| "truncate", |
| "writable", |
| "write", |
| "writelines", |
| ) |
| @proxy_method_directly("detach", "fileno", "readable") |
| @proxy_property_directly("closed", "raw", "name", "mode") |
| class AsyncBufferedIOBase(AsyncBase): |
| """The asyncio executor version of io.BufferedWriter and BufferedIOBase.""" |
|
|
|
|
| @delegate_to_executor("peek") |
| class AsyncBufferedReader(AsyncBufferedIOBase): |
| """The asyncio executor version of io.BufferedReader and Random.""" |
|
|
|
|
| @delegate_to_executor( |
| "close", |
| "flush", |
| "isatty", |
| "read", |
| "readall", |
| "readinto", |
| "readline", |
| "readlines", |
| "seek", |
| "seekable", |
| "tell", |
| "truncate", |
| "writable", |
| "write", |
| "writelines", |
| ) |
| @proxy_method_directly("fileno", "readable") |
| @proxy_property_directly("closed", "name", "mode") |
| class AsyncFileIO(AsyncBase): |
| """The asyncio executor version of io.FileIO.""" |
|
|
|
|
| @delegate_to_executor( |
| "close", |
| "flush", |
| "isatty", |
| "read", |
| "read1", |
| "readinto", |
| "readline", |
| "readlines", |
| "seek", |
| "seekable", |
| "tell", |
| "truncate", |
| "writable", |
| "write", |
| "writelines", |
| ) |
| @proxy_method_directly("detach", "fileno", "readable") |
| @proxy_property_directly("closed", "raw", "name", "mode") |
| class AsyncIndirectBufferedIOBase(AsyncIndirectBase): |
| """The indirect asyncio executor version of io.BufferedWriter and BufferedIOBase.""" |
|
|
|
|
| @delegate_to_executor("peek") |
| class AsyncIndirectBufferedReader(AsyncIndirectBufferedIOBase): |
| """The indirect asyncio executor version of io.BufferedReader and Random.""" |
|
|
|
|
| @delegate_to_executor( |
| "close", |
| "flush", |
| "isatty", |
| "read", |
| "readall", |
| "readinto", |
| "readline", |
| "readlines", |
| "seek", |
| "seekable", |
| "tell", |
| "truncate", |
| "writable", |
| "write", |
| "writelines", |
| ) |
| @proxy_method_directly("fileno", "readable") |
| @proxy_property_directly("closed", "name", "mode") |
| class AsyncIndirectFileIO(AsyncIndirectBase): |
| """The indirect asyncio executor version of io.FileIO.""" |
|
|
