fromtypingimportCallable,Any,ParamSpecArgs,ParamSpecKwargs

defeagain_errcode(func:Callable,poller_func:Callable,*args:ParamSpecArgs,**kwargs:ParamSpecKwargs)->Any: ...

defeagain_write_errcode(write_func:Callable,poller_func:Callable,data:bytes)->None: ...

from typingimport Callable, Any

from typingimport Callable, Any, ParamSpecArgs, ParamSpecKwargs

from . cimport error_codes

from .utilsimport find_eol

defeagain_errcode(func:Callable, poller_func:Callable, *args, **kwargs) -> Any:

defeagain_errcode(func:Callable, poller_func:Callable, *args:ParamSpecArgs, **kwargs:ParamSpecKwargs) -> Any:

"""Helper function for reading in non-blocking mode.

Any additional arguments and keyword arguments provided are used as arguments to the session function `func`.

returnret

def eagain_write_errcode(write_func:Callable, poller_func:Callable, bytes data:bytes) -> None:

def eagain_write_errcode(write_func:Callable, poller_func:Callable, bytesdata) -> None:

"""Helper function for writing in non-blocking mode.

Any additional arguments and keyword arguments provided are used as arguments to the session function `write_func`.