Slight typing and multi-line styling tweaks in `.ipc` sugpkg
parent
47d66e6c0b
commit
544b5bdd9c
|
@ -50,7 +50,10 @@ if _USE_POSIX:
|
||||||
try:
|
try:
|
||||||
import numpy as np
|
import numpy as np
|
||||||
from numpy.lib import recfunctions as rfn
|
from numpy.lib import recfunctions as rfn
|
||||||
import nptyping
|
# TODO ruff complains with,
|
||||||
|
# warning| F401: `nptyping` imported but unused; consider using
|
||||||
|
# `importlib.util.find_spec` to test for availability
|
||||||
|
import nptyping # noqa
|
||||||
except ImportError:
|
except ImportError:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
|
@ -157,7 +157,10 @@ class MsgpackTransport(MsgTransport):
|
||||||
|
|
||||||
) -> None:
|
) -> None:
|
||||||
self.stream = stream
|
self.stream = stream
|
||||||
self._laddr, self._raddr = self.get_stream_addrs(stream)
|
(
|
||||||
|
self._laddr,
|
||||||
|
self._raddr,
|
||||||
|
) = self.get_stream_addrs(stream)
|
||||||
|
|
||||||
# create read loop instance
|
# create read loop instance
|
||||||
self._aiter_pkts = self._iter_packets()
|
self._aiter_pkts = self._iter_packets()
|
||||||
|
|
|
@ -76,7 +76,7 @@ def transport_from_stream(
|
||||||
'''
|
'''
|
||||||
transport = None
|
transport = None
|
||||||
if isinstance(stream, trio.SocketStream):
|
if isinstance(stream, trio.SocketStream):
|
||||||
sock = stream.socket
|
sock: socket.socket = stream.socket
|
||||||
match sock.family:
|
match sock.family:
|
||||||
case socket.AF_INET | socket.AF_INET6:
|
case socket.AF_INET | socket.AF_INET6:
|
||||||
transport = 'tcp'
|
transport = 'tcp'
|
||||||
|
|
Loading…
Reference in New Issue