syndicate-lang
/
syndicate-js
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Terminate server once last connection goes

This commit is contained in:
Tony Garnock-Jones 2019-06-21 17:23:08 +01:00
parent a4d875e03c
commit 4cd8b58d1a
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/syntax-playground/src/echo-server-syndicate-js.js
View File

@ -1,10 +1,14 @@
const S = activate require("@syndicate-lang/driver-streams-node"); const S = activate require("@syndicate-lang/driver-streams-node");
assertion type ConnectionActive();
spawn named 'echoserver' { spawn named 'echoserver' {
on asserted S.Stream($id, S.Incoming(S.TcpListener(5999))) { on asserted S.Stream($id, S.Incoming(S.TcpListener(5999))) {
spawn { spawn {
assert ConnectionActive();
stop on retracted S.Stream(id, S.Duplex()); stop on retracted S.Stream(id, S.Duplex());
on message S.Stream(id, S.Data($bs)) send S.Stream(id, S.Push(bs, false)); on message S.Stream(id, S.Data($bs)) send S.Stream(id, S.Push(bs, false));
} }
} }
stop on retracted ConnectionActive();
} }