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

Correct usages of `stop` to conform to new semantics

This commit is contained in:
Tony Garnock-Jones 2024-03-09 23:06:00 +01:00
parent 2bcffd3bab
commit 31f11d2389
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/service/src/index.ts
View File

@ -22,8 +22,8 @@ export function service(handler: (args: AnyValue) => void, options?: ServiceOpti
packetWriter: (bs: Uint8Array) => process.stdout.write(bs),
setup(r: Relay.Relay) {
process.stdin.on('data', bs => facet.turn(() => r.accept(new Uint8Array(bs))));
process.stdin.on('close', () => facet.turn(() => { stop {} }));
process.stdin.on('end', () => facet.turn(() => { stop {} }));
process.stdin.on('close', () => facet.turn(() => { stop facet; }));
process.stdin.on('end', () => facet.turn(() => { stop facet; }));
},
initialRef: Turn.ref(assertionFacetObserver(handler)),
}, options ?? {}));

6
packages/ws-relay/src/index.ts
View File

@ -64,7 +64,7 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon
message(a0: Assertion): void {
const a = G.toTransportControl(a0);
if (!a) return;
stop {} // ForceDisconnect
stop facet; // ForceDisconnect
},
};
let final = false;
@ -76,7 +76,7 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon
console.log('closing', addr.url);
ws.close();
}
ws.onclose = () => facet.turn(() => { stop {} });
ws.onclose = () => facet.turn(() => { stop facet; });
ws.onerror = () => facet.turn(() =>
Turn.active.crash(new Error("WebSocket error")));
const relay = new Relay.Relay({
@ -109,7 +109,7 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon
"resolved": G.Resolved.Rejected(G.Rejected(detail)),
});
}
setTimeout(() => facet.turn(() => { stop {} }), 10000);
setTimeout(() => facet.turn(() => { stop facet; }), 10000);
}
try {
const ws = new (WebSocketConstructor ?? WebSocket)(addr.url);