mirror of
https://github.com/ansible-collections/community.docker.git
synced 2026-10-27 08:41:13 +00:00
Fix type hints.
This commit is contained in:
@@ -155,14 +155,14 @@ class NpipeSocket:
|
|||||||
return io.BufferedReader(rawio, buffer_size=bufsize)
|
return io.BufferedReader(rawio, buffer_size=bufsize)
|
||||||
|
|
||||||
@check_closed
|
@check_closed
|
||||||
def recv(self, bufsize: int, flags: int = 0) -> str:
|
def recv(self, bufsize: int, flags: int = 0) -> bytes:
|
||||||
if self._handle is None:
|
if self._handle is None:
|
||||||
raise ValueError("Handle not present")
|
raise ValueError("Handle not present")
|
||||||
dummy_err, data = win32file.ReadFile(self._handle, bufsize)
|
dummy_err, data = win32file.ReadFile(self._handle, bufsize)
|
||||||
return data
|
return data
|
||||||
|
|
||||||
@check_closed
|
@check_closed
|
||||||
def recvfrom(self, bufsize: int, flags: int = 0) -> tuple[str, str | None]:
|
def recvfrom(self, bufsize: int, flags: int = 0) -> tuple[bytes, str | None]:
|
||||||
data = self.recv(bufsize, flags)
|
data = self.recv(bufsize, flags)
|
||||||
return (data, self._address)
|
return (data, self._address)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user