Kalm

// Server
const Kalm = require('kalm');
const ws = require('@kalm/ws');

const server = Kalm.listen({
  port: 9001,
  transport: ws(),
});

server.on('connection', (client) => {
  client.subscribe('chat', (data) => {
    // Broadcast to all clients
    server.broadcast('chat', data);
  });
});

// Client
const client = Kalm.connect({
  host: '0.0.0.0',
  port: 9001,
  transport: ws(),
});

client.on('connect', () => {
  client.subscribe('chat', (data) => {
    console.log(data.user + ': ' + data.message);
  });

  client.write('chat', {
    user: 'User',
    message: 'Hello World!',
  });
});