.config/coc/extensions/node_modules/coc-pyright/node_modules/pyright/dist/typeshed-fallback/stdlib/asyncio/proactor_events.pyi

   1 import sys
   2 from socket import socket
   3 from typing import Any, Mapping, Type
   4 from typing_extensions import Literal, Protocol
   5
   6 from . import base_events, constants, events, futures, streams, transports
   7
   8 if sys.version_info >= (3, 8):
   9     class _WarnCallbackProtocol(Protocol):
  10         def __call__(
  11             self, message: str, category: Type[Warning] | None = ..., stacklevel: int = ..., source: Any | None = ...
  12         ) -> None: ...
  13
  14 class _ProactorBasePipeTransport(transports._FlowControlMixin, transports.BaseTransport):
  15     def __init__(
  16         self,
  17         loop: events.AbstractEventLoop,
  18         sock: socket,
  19         protocol: streams.StreamReaderProtocol,
  20         waiter: futures.Future[Any] | None = ...,
  21         extra: Mapping[Any, Any] | None = ...,
  22         server: events.AbstractServer | None = ...,
  23     ) -> None: ...
  24     def __repr__(self) -> str: ...
  25     if sys.version_info >= (3, 8):
  26         def __del__(self, _warn: _WarnCallbackProtocol = ...) -> None: ...
  27     else:
  28         def __del__(self) -> None: ...
  29     def get_write_buffer_size(self) -> int: ...
  30
  31 class _ProactorReadPipeTransport(_ProactorBasePipeTransport, transports.ReadTransport):
  32     def __init__(
  33         self,
  34         loop: events.AbstractEventLoop,
  35         sock: socket,
  36         protocol: streams.StreamReaderProtocol,
  37         waiter: futures.Future[Any] | None = ...,
  38         extra: Mapping[Any, Any] | None = ...,
  39         server: events.AbstractServer | None = ...,
  40     ) -> None: ...
  41
  42 class _ProactorBaseWritePipeTransport(_ProactorBasePipeTransport, transports.WriteTransport):
  43     def __init__(
  44         self,
  45         loop: events.AbstractEventLoop,
  46         sock: socket,
  47         protocol: streams.StreamReaderProtocol,
  48         waiter: futures.Future[Any] | None = ...,
  49         extra: Mapping[Any, Any] | None = ...,
  50         server: events.AbstractServer | None = ...,
  51     ) -> None: ...
  52
  53 class _ProactorWritePipeTransport(_ProactorBaseWritePipeTransport):
  54     def __init__(
  55         self,
  56         loop: events.AbstractEventLoop,
  57         sock: socket,
  58         protocol: streams.StreamReaderProtocol,
  59         waiter: futures.Future[Any] | None = ...,
  60         extra: Mapping[Any, Any] | None = ...,
  61         server: events.AbstractServer | None = ...,
  62     ) -> None: ...
  63
  64 class _ProactorDuplexPipeTransport(_ProactorReadPipeTransport, _ProactorBaseWritePipeTransport, transports.Transport): ...
  65
  66 class _ProactorSocketTransport(_ProactorReadPipeTransport, _ProactorBaseWritePipeTransport, transports.Transport):
  67
  68     _sendfile_compatible: constants._SendfileMode
  69     def __init__(
  70         self,
  71         loop: events.AbstractEventLoop,
  72         sock: socket,
  73         protocol: streams.StreamReaderProtocol,
  74         waiter: futures.Future[Any] | None = ...,
  75         extra: Mapping[Any, Any] | None = ...,
  76         server: events.AbstractServer | None = ...,
  77     ) -> None: ...
  78     def _set_extra(self, sock: socket) -> None: ...
  79     def can_write_eof(self) -> Literal[True]: ...
  80     def write_eof(self) -> None: ...
  81
  82 class BaseProactorEventLoop(base_events.BaseEventLoop):
  83     def __init__(self, proactor: Any) -> None: ...