diff --git a/src/syndicate/relays.nim b/src/syndicate/relays.nim index 397b0c0..417d42b 100644 --- a/src/syndicate/relays.nim +++ b/src/syndicate/relays.nim @@ -318,12 +318,12 @@ proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: Connec run(facet) do (turn: var Turn): stopActor(turn) else: if wireBuf.len == 0: wireBuf = move buf - else: wireBuf.add(buf) + else: wireBuf.add(move buf) try: var pr = decodePreserves(wireBuf, WireRef) dispatch(relay, cast[Preserve[WireRef]](pr)) wireBuf.setLen(0) - except ValueError: discard + except IOError, ValueError: discard socket.recv(recvSize).addCallback(recvCb) # TODO: should this need be callSoon? socket.recv(recvSize).addCallback(recvCb) diff --git a/src/syndicate/unix/swaybar_status_actor.nim b/src/syndicate/unix/swaybar_status_actor.nim index 8858c2b..248f2c5 100644 --- a/src/syndicate/unix/swaybar_status_actor.nim +++ b/src/syndicate/unix/swaybar_status_actor.nim @@ -49,6 +49,5 @@ bootDataspace("main") do (root: Ref; turn: var Turn): sendLine(turn) do: lineElements.excl a - sendLine(turn) runForever()