self.recvfrom.set_exception(exc)
def close(self):
- self.transport.close()
+ if self.transport is not None:
+ self.transport.close()
async def _maybe_wait_for(awaitable, timeout):
)
async def connect_tcp(
- self, host, port, timeout, local_address, socket_options=None
+ self, host, port, timeout=None, local_address=None, socket_options=None
): # pylint: disable=signature-differs
addresses = []
_, expiration = _compute_times(timeout)
raise httpcore.ConnectError
async def connect_unix_socket(
- self, path, timeout, socket_options=None
+ self, path, timeout=None, socket_options=None
): # pylint: disable=signature-differs
raise NotImplementedError
# proper fix for [#637].
source = (dns.inet.any_for_af(af), 0)
transport, protocol = await loop.create_datagram_endpoint(
- _DatagramProtocol,
+ _DatagramProtocol, # pyright: ignore
source,
family=af,
proto=proto,
self._family = family
async def connect_tcp(
- self, host, port, timeout, local_address, socket_options=None
+ self, host, port, timeout=None, local_address=None, socket_options=None
): # pylint: disable=signature-differs
addresses = []
_, expiration = _compute_times(timeout)
sock = await Backend().make_socket(
af, socket.SOCK_STREAM, 0, source, destination, timeout
)
+ assert isinstance(sock, StreamSocket)
return _CoreTrioStream(sock.stream)
except Exception:
continue
raise httpcore.ConnectError
async def connect_unix_socket(
- self, path, timeout, socket_options=None
+ self, path, timeout=None, socket_options=None
): # pylint: disable=signature-differs
raise NotImplementedError
if socktype == socket.SOCK_STREAM or destination is not None:
connected = False
with _maybe_timeout(timeout):
+ assert destination is not None
await s.connect(_lltuple(destination, af))
connected = True
if not connected: