diff --git a/packages/driver-streams-node/src/streams.js b/packages/driver-streams-node/src/streams.js index 01344bc..0ecda3f 100644 --- a/packages/driver-streams-node/src/streams.js +++ b/packages/driver-streams-node/src/streams.js @@ -245,7 +245,7 @@ spawn named 'driver/stream-line' { } export function spawnConnection(id, spec, s) { - spawn named ['IncomingConnection', id] { + spawn named ['IncomingConnection', id, spec] { assert IncomingConnection(id, spec); stop on retracted Observe(IncomingConnection(_, spec)) s.destroy(); stop on message ConnectionRejected(id, $err) s.destroy(err);