example.server.skt

#!/usr/bin/env node
const http = require('http');
const SktServer = require('./index').SktServer;

var httpServer = http.createServer((request, response) => {
  console.log((new Date()) + ' Received request for ' + request.url);
  response.writeHead(404);
  response.end();
});

httpServer.listen(7000, () => {
    console.log((new Date()) + ' Server is listening on port 7000');
});

// asyncConnectToSocket
(async () => {
	let { Receiver, Emmiter } = await SktServer.init({ httpServer });
	Receiver
	.subscribe('message', data => {
		console.log(data);
	});
	Emmiter
	.emmit('my message');
})()