diff --git a/tractor/_ipc.py b/tractor/_ipc.py index f3a7b44..13bceb0 100644 --- a/tractor/_ipc.py +++ b/tractor/_ipc.py @@ -2,7 +2,6 @@ Inter-process comms abstractions """ from functools import partial -import math import struct import typing from typing import Any, Tuple, Optional @@ -49,9 +48,8 @@ class MsgpackTCPStream: assert isinstance(rsockname, tuple) self._raddr = rsockname[:2] - # start and seed first entry to read loop + # start first entry to read loop self._agen = self._iter_packets() - # self._agen.asend(None) is None self._send_lock = trio.StrictFIFOLock() @@ -225,7 +223,6 @@ class Channel: stream = await trio.open_tcp_stream( *destaddr, - happy_eyeballs_delay=math.inf, **kwargs ) self.msgstream = self.stream_serializer_type(stream)