From afccc4172ab9f1da7413b509bc75c58c1a9a271d Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 15 Nov 2018 23:52:48 +0000 Subject: [PATCH] Tweak stub broker index.js --- packages/broker/src/index.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/broker/src/index.js b/packages/broker/src/index.js index 12b29da..ae269fd 100644 --- a/packages/broker/src/index.js +++ b/packages/broker/src/index.js @@ -6,7 +6,7 @@ const UI = require("@syndicate-lang/driver-browser-ui"); const Http = activate require("@syndicate-lang/driver-http-node"); const Tcp = activate require("@syndicate-lang/driver-tcp-node"); -// import { currentFacet } from "@syndicate-lang/core"; +import { Decoder, Bytes } from "@syndicate-lang/core"; const server = Http.HttpServer(null, 8000); @@ -34,11 +34,11 @@ spawn named 'rootServer' { spawn named 'websocketListener' { during Http.WebSocket($reqId, server, ['broker'], _) spawn named ['wsConnection', reqId] { on message Http.DataIn(reqId, $message) { - console.log('got', reqId, new (require('preserves').Decoder)(message).next()) + console.log('got', reqId, new Decoder(message).next()); ^ Http.DataOut(reqId, message); } - stop on message Http.DataIn(reqId, "quit"); + stop on message Http.DataIn(reqId, Bytes.from("quit")); } }