Remove duplicate definitions (#8483)

stdlib/asyncio/base_subprocess.pyi

@@ -44,17 +44,10 @@ class BaseSubprocessTransport(transports.SubprocessTransport):
         bufsize: int,
         **kwargs: Any,
     ) -> None: ...  # undocumented
-    def set_protocol(self, protocol: protocols.BaseProtocol) -> None: ...
-    def get_protocol(self) -> protocols.BaseProtocol: ...
-    def is_closing(self) -> bool: ...
-    def close(self) -> None: ...
     def get_pid(self) -> int | None: ...  # type: ignore[override]
-    def get_returncode(self) -> int | None: ...
     def get_pipe_transport(self, fd: int) -> _File: ...  # type: ignore[override]
     def _check_proc(self) -> None: ...  # undocumented
     def send_signal(self, signal: int) -> None: ...  # type: ignore[override]
-    def terminate(self) -> None: ...
-    def kill(self) -> None: ...
     async def _connect_pipes(self, waiter: futures.Future[Any] | None) -> None: ...  # undocumented
     def _call(self, cb: Callable[..., object], *data: Any) -> None: ...  # undocumented
     def _pipe_connection_lost(self, fd: int, exc: BaseException | None) -> None: ...  # undocumented
@@ -66,10 +59,5 @@ class BaseSubprocessTransport(transports.SubprocessTransport):
 
 class WriteSubprocessPipeProto(protocols.BaseProtocol):  # undocumented
     def __init__(self, proc: BaseSubprocessTransport, fd: int) -> None: ...
-    def connection_made(self, transport: transports.BaseTransport) -> None: ...
-    def connection_lost(self, exc: BaseException | None) -> None: ...
-    def pause_writing(self) -> None: ...
-    def resume_writing(self) -> None: ...
 
-class ReadSubprocessPipeProto(WriteSubprocessPipeProto, protocols.Protocol):  # undocumented
-    def data_received(self, data: bytes) -> None: ...
+class ReadSubprocessPipeProto(WriteSubprocessPipeProto, protocols.Protocol): ...  # undocumented

stdlib/asyncio/events.pyi

@@ -91,7 +91,6 @@ class TimerHandle(Handle):
     def __le__(self, other: TimerHandle) -> bool: ...
     def __gt__(self, other: TimerHandle) -> bool: ...
     def __ge__(self, other: TimerHandle) -> bool: ...
-    def __eq__(self, other: object) -> bool: ...
 
 class AbstractServer:
     @abstractmethod
@@ -612,7 +611,6 @@ class AbstractEventLoopPolicy:
     def set_child_watcher(self, watcher: AbstractChildWatcher) -> None: ...
 
 class BaseDefaultEventLoopPolicy(AbstractEventLoopPolicy, metaclass=ABCMeta):
-    def __init__(self) -> None: ...
     def get_event_loop(self) -> AbstractEventLoop: ...
     def set_event_loop(self, loop: AbstractEventLoop | None) -> None: ...
     def new_event_loop(self) -> AbstractEventLoop: ...

stdlib/asyncio/locks.pyi

@@ -92,11 +92,7 @@ class Semaphore(_ContextManagerMixin):
     def release(self) -> None: ...
     def _wake_up_next(self) -> None: ...
 
-class BoundedSemaphore(Semaphore):
-    if sys.version_info >= (3, 11):
-        def __init__(self, value: int = ...) -> None: ...
-    else:
-        def __init__(self, value: int = ..., *, loop: AbstractEventLoop | None = ...) -> None: ...
+class BoundedSemaphore(Semaphore): ...
 
 if sys.version_info >= (3, 11):
     class _BarrierState(enum.Enum):  # undocumented

stdlib/asyncio/proactor_events.pyi

@@ -29,8 +29,6 @@ class _ProactorBasePipeTransport(transports._FlowControlMixin, transports.BaseTr
     else:
         def __del__(self) -> None: ...
 
-    def get_write_buffer_size(self) -> int: ...
-
 class _ProactorReadPipeTransport(_ProactorBasePipeTransport, transports.ReadTransport):
     if sys.version_info >= (3, 10):
         def __init__(
@@ -54,28 +52,8 @@ class _ProactorReadPipeTransport(_ProactorBasePipeTransport, transports.ReadTran
             server: events.AbstractServer | None = ...,
         ) -> None: ...
 
-class _ProactorBaseWritePipeTransport(_ProactorBasePipeTransport, transports.WriteTransport):
-    def __init__(
-        self,
-        loop: events.AbstractEventLoop,
-        sock: socket,
-        protocol: streams.StreamReaderProtocol,
-        waiter: futures.Future[Any] | None = ...,
-        extra: Mapping[Any, Any] | None = ...,
-        server: events.AbstractServer | None = ...,
-    ) -> None: ...
-
-class _ProactorWritePipeTransport(_ProactorBaseWritePipeTransport):
-    def __init__(
-        self,
-        loop: events.AbstractEventLoop,
-        sock: socket,
-        protocol: streams.StreamReaderProtocol,
-        waiter: futures.Future[Any] | None = ...,
-        extra: Mapping[Any, Any] | None = ...,
-        server: events.AbstractServer | None = ...,
-    ) -> None: ...
-
+class _ProactorBaseWritePipeTransport(_ProactorBasePipeTransport, transports.WriteTransport): ...
+class _ProactorWritePipeTransport(_ProactorBaseWritePipeTransport): ...
 class _ProactorDuplexPipeTransport(_ProactorReadPipeTransport, _ProactorBaseWritePipeTransport, transports.Transport): ...
 
 class _ProactorSocketTransport(_ProactorReadPipeTransport, _ProactorBaseWritePipeTransport, transports.Transport):
@@ -92,7 +70,6 @@ class _ProactorSocketTransport(_ProactorReadPipeTransport, _ProactorBaseWritePip
     ) -> None: ...
     def _set_extra(self, sock: socket) -> None: ...
     def can_write_eof(self) -> Literal[True]: ...
-    def write_eof(self) -> None: ...
 
 class BaseProactorEventLoop(base_events.BaseEventLoop):
     def __init__(self, proactor: Any) -> None: ...

stdlib/asyncio/sslproto.pyi

@@ -72,20 +72,10 @@ class _SSLProtocolTransport(transports._FlowControlMixin, transports.Transport):
     _closed: bool
     def __init__(self, loop: events.AbstractEventLoop, ssl_protocol: SSLProtocol) -> None: ...
     def get_extra_info(self, name: str, default: Any | None = ...) -> dict[str, Any]: ...
-    def set_protocol(self, protocol: protocols.BaseProtocol) -> None: ...
-    def get_protocol(self) -> protocols.BaseProtocol: ...
-    def is_closing(self) -> bool: ...
-    def close(self) -> None: ...
-    def is_reading(self) -> bool: ...
-    def pause_reading(self) -> None: ...
-    def resume_reading(self) -> None: ...
-    def set_write_buffer_limits(self, high: int | None = ..., low: int | None = ...) -> None: ...
-    def get_write_buffer_size(self) -> int: ...
     @property
     def _protocol_paused(self) -> bool: ...
     def write(self, data: bytes) -> None: ...
     def can_write_eof(self) -> Literal[False]: ...
-    def abort(self) -> None: ...
     if sys.version_info >= (3, 11):
         def get_write_buffer_limits(self) -> tuple[int, int]: ...
         def get_read_buffer_limits(self) -> tuple[int, int]: ...
@@ -149,10 +139,7 @@ class SSLProtocol(_SSLProtocolBase):
 
     def _set_app_protocol(self, app_protocol: protocols.BaseProtocol) -> None: ...
     def _wakeup_waiter(self, exc: BaseException | None = ...) -> None: ...
-    def connection_made(self, transport: transports.BaseTransport) -> None: ...
     def connection_lost(self, exc: BaseException | None) -> None: ...
-    def pause_writing(self) -> None: ...
-    def resume_writing(self) -> None: ...
     def eof_received(self) -> None: ...
     def _get_extra_info(self, name: str, default: Any | None = ...) -> Any: ...
     def _start_shutdown(self) -> None: ...
@@ -167,9 +154,7 @@ class SSLProtocol(_SSLProtocolBase):
     def _fatal_error(self, exc: BaseException, message: str = ...) -> None: ...
     def _abort(self) -> None: ...
     if sys.version_info >= (3, 11):
-        def buffer_updated(self, nbytes: int) -> None: ...
         def get_buffer(self, n: int) -> memoryview: ...
     else:
         def _finalize(self) -> None: ...
         def _process_write_backlog(self) -> None: ...
-        def data_received(self, data: bytes) -> None: ...

stdlib/asyncio/streams.pyi

@@ -128,10 +128,6 @@ class StreamReaderProtocol(FlowControlMixin, protocols.Protocol):
         client_connected_cb: _ClientConnectedCallback | None = ...,
         loop: events.AbstractEventLoop | None = ...,
     ) -> None: ...
-    def connection_made(self, transport: transports.BaseTransport) -> None: ...
-    def connection_lost(self, exc: Exception | None) -> None: ...
-    def data_received(self, data: bytes) -> None: ...
-    def eof_received(self) -> bool: ...
 
 class StreamWriter:
     def __init__(

stdlib/asyncio/subprocess.pyi

@@ -22,10 +22,7 @@ class SubprocessStreamProtocol(streams.FlowControlMixin, protocols.SubprocessPro
     stdout: streams.StreamReader | None
     stderr: streams.StreamReader | None
     def __init__(self, limit: int, loop: events.AbstractEventLoop) -> None: ...
-    def connection_made(self, transport: transports.BaseTransport) -> None: ...
     def pipe_data_received(self, fd: int, data: bytes | str) -> None: ...
-    def pipe_connection_lost(self, fd: int, exc: Exception | None) -> None: ...
-    def process_exited(self) -> None: ...
 
 class Process:
     stdin: streams.StreamWriter | None

stdlib/asyncio/tasks.pyi

@@ -285,10 +285,6 @@ class Task(Future[_T], Generic[_T]):
 
     def get_stack(self, *, limit: int | None = ...) -> list[FrameType]: ...
     def print_stack(self, *, limit: int | None = ..., file: TextIO | None = ...) -> None: ...
-    if sys.version_info >= (3, 9):
-        def cancel(self, msg: Any | None = ...) -> bool: ...
-    else:
-        def cancel(self) -> bool: ...
     if sys.version_info >= (3, 11):
         def cancelling(self) -> int: ...
         def uncancel(self) -> int: ...

stdlib/asyncio/transports.pyi

@@ -45,6 +45,3 @@ class SubprocessTransport(BaseTransport):
 
 class _FlowControlMixin(Transport):
     def __init__(self, extra: Mapping[Any, Any] | None = ..., loop: AbstractEventLoop | None = ...) -> None: ...
-    def set_write_buffer_limits(self, high: int | None = ..., low: int | None = ...) -> None: ...
-    def get_write_buffer_size(self) -> int: ...
-    def get_write_buffer_limits(self) -> tuple[int, int]: ...

stdlib/asyncio/unix_events.pyi

@@ -57,7 +57,6 @@ if sys.platform != "win32":
     # Doesn't actually have ABCMeta metaclass at runtime, but mypy complains if we don't have it in the stub.
     # See discussion in #7412
     class BaseChildWatcher(AbstractChildWatcher, metaclass=ABCMeta):
-        def __init__(self) -> None: ...
         def close(self) -> None: ...
         if sys.version_info >= (3, 8):
             def is_active(self) -> bool: ...
@@ -95,7 +94,6 @@ if sys.platform != "win32":
             ) -> object: ...
 
         class MultiLoopChildWatcher(AbstractChildWatcher):
-            def __init__(self) -> None: ...
             def is_active(self) -> bool: ...
             def close(self) -> None: ...
             def __enter__(self: Self) -> Self: ...
@@ -107,7 +105,6 @@ if sys.platform != "win32":
             def attach_loop(self, loop: AbstractEventLoop | None) -> None: ...
 
         class ThreadedChildWatcher(AbstractChildWatcher):
-            def __init__(self) -> None: ...
             def is_active(self) -> Literal[True]: ...
             def close(self) -> None: ...
             def __enter__(self: Self) -> Self: ...