Fixes

Author: gzukowski

raspberry-pi/cl_seq/index.js

@@ -1,24 +1,26 @@
-const { PassThrough } = require("stream");
 const ws = require('ws');
+const PassThrough = require('stream');
 
 
+const topic = "topic";
 
-module.exports = [
-    { requires: "pipe", contentType: 'text/plain' },
-    function(input) {
-		const client = new ws('ws://localhost:3000');
-        const out = new PassThrough({ objectMode: true });
+module.exports = async function (input){
+	const client = new ws('ws://localhost:3000');
 
-		async function reader(client) {
-			for await (const chunk of input) {
-				client.send(chunk);
-			}
-		  }
-		client.on('open', () => {
-			reader(client);
-		});
-        
+	async function reader(client) {
+		for await (const chunk of input) {
+			client.send(chunk);
+		}
+  	}
 
-        return out;
-    }
-];
+	client.on('open', function open() {
+		client.send('something');
+	  });
+
+
+  	client.on('message', function message(data) {
+		console.log('client received: %s', data);
+	  });
+
+return input;
+}