1
1
import sys
2
2
from collections .abc import Mapping
3
3
from socket import socket
4
- from typing import Any , Protocol
4
+ from typing import Any , ClassVar , Protocol
5
5
from typing_extensions import Literal
6
6
7
7
from . import base_events , constants , events , futures , streams , transports
@@ -29,8 +29,6 @@ class _ProactorBasePipeTransport(transports._FlowControlMixin, transports.BaseTr
29
29
else :
30
30
def __del__ (self ) -> None : ...
31
31
32
- def get_write_buffer_size (self ) -> int : ...
33
-
34
32
class _ProactorReadPipeTransport (_ProactorBasePipeTransport , transports .ReadTransport ):
35
33
if sys .version_info >= (3 , 10 ):
36
34
def __init__ (
@@ -54,33 +52,13 @@ class _ProactorReadPipeTransport(_ProactorBasePipeTransport, transports.ReadTran
54
52
server : events .AbstractServer | None = ...,
55
53
) -> None : ...
56
54
57
- class _ProactorBaseWritePipeTransport (_ProactorBasePipeTransport , transports .WriteTransport ):
58
- def __init__ (
59
- self ,
60
- loop : events .AbstractEventLoop ,
61
- sock : socket ,
62
- protocol : streams .StreamReaderProtocol ,
63
- waiter : futures .Future [Any ] | None = ...,
64
- extra : Mapping [Any , Any ] | None = ...,
65
- server : events .AbstractServer | None = ...,
66
- ) -> None : ...
67
-
68
- class _ProactorWritePipeTransport (_ProactorBaseWritePipeTransport ):
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
-
55
+ class _ProactorBaseWritePipeTransport (_ProactorBasePipeTransport , transports .WriteTransport ): ...
56
+ class _ProactorWritePipeTransport (_ProactorBaseWritePipeTransport ): ...
79
57
class _ProactorDuplexPipeTransport (_ProactorReadPipeTransport , _ProactorBaseWritePipeTransport , transports .Transport ): ...
80
58
81
59
class _ProactorSocketTransport (_ProactorReadPipeTransport , _ProactorBaseWritePipeTransport , transports .Transport ):
82
60
83
- _sendfile_compatible : constants ._SendfileMode
61
+ _sendfile_compatible : ClassVar [ constants ._SendfileMode ]
84
62
def __init__ (
85
63
self ,
86
64
loop : events .AbstractEventLoop ,
@@ -92,7 +70,6 @@ class _ProactorSocketTransport(_ProactorReadPipeTransport, _ProactorBaseWritePip
92
70
) -> None : ...
93
71
def _set_extra (self , sock : socket ) -> None : ...
94
72
def can_write_eof (self ) -> Literal [True ]: ...
95
- def write_eof (self ) -> None : ...
96
73
97
74
class BaseProactorEventLoop (base_events .BaseEventLoop ):
98
75
def __init__ (self , proactor : Any ) -> None : ...
0 commit comments