diff --git a/src/syndicate/relays.nim b/src/syndicate/relays.nim index 281615d..cef4b05 100644 --- a/src/syndicate/relays.nim +++ b/src/syndicate/relays.nim @@ -287,7 +287,7 @@ method retract(e: ShutdownEntity; turn: var Turn; h: Handle) = type SturdyRef = sturdy.SturdyRef[Ref] Resolve = gatekeeper.Resolve[Ref] - ConnectProc* = proc (turn: var Turn; a: Assertion): TurnAction {.gcsafe.} + ConnectProc* = proc (turn: var Turn; ds: Ref) {.gcsafe.} proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: ConnectProc) = var socket = newAsyncSocket( @@ -335,9 +335,9 @@ proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: Connec run(gatekeeper.relay) do (turn: var Turn): reenable() discard publish(turn, shutdownRef, true) - proc duringCallback(turn: var Turn; ds: Assertion; h: Handle): TurnAction = + proc duringCallback(turn: var Turn; a: Assertion; h: Handle): TurnAction = let facet = facet(turn) do (turn: var Turn): - discard bootProc(turn, ds) # TODO: what to do with this? + bootProc(turn, unembed a) proc action(turn: var Turn) = stop(turn, facet) result = action