Kalm 0,0,0,0,0 travis-ci npm

Node socket wrapper and optimizer


The Socket Optimizer

Kalm Build Status Dependencies Status Code Climate Gitter Flattr

Simplify and optimize your Socket communications with:

  • Easy-to-use single syntax for all protocols
  • Configurable packet bundling (High-level Naggle’s algorithm implementation)
  • Multiplexing for all protocols
  • Ultra-flexible and extensible, load your own adapters and encoders


  • NODE >= 6.0.0

  • Webpack 1 || 2.1.x

Performance analysis

Requests per minute

Benchmarks based on a single-thread queue test with Kalm default bundling settings

Bytes transfered

Number of protocol overhead bytes saved per request


npm install kalm



    var Kalm = require('kalm');

    // Create a server, listening for incoming connections
    var server = new Kalm.Server({
      port: 6000,
      adapter: 'udp',
      encoder: 'json',
      channels: {
        messageEvent: function(data) {               // Handler - new connections will register to these events
          console.log('User sent message ' + data.body);

    // When a connection is received, send a message to all connected users
    server.on('connection', function(client) {    // Handler, where client is an instance of Kalm.Client
      server.broadcast('userEvent', 'A new user has connected');  


    // Opens a connection to the server
    var client = new Kalm.Client({
      hostname: '', // Server's IP
      port: 6000, // Server's port
      adapter: 'udp', // Server's adapter
      encoder: 'json', // Server's encoder
      channels: {
        'userEvent': function(data) {
          console.log('Server: ' + data);

    client.send('messageEvent', {body: 'This is an object!'}); 
    client.subscribe('someOtherEvent', function() {});


API docs



Loading custom adapters

The framework is flexible enough so that you can load your own custom adapters, encoders or middlewares

    // Custom adapter loading example
    var Kalm = require('kalm');
    var WebRTC = require('kalm-webrtc');
    var msgpack = require('kalm-msgpack');

    Kalm.adapters.register('webrtc', WebRTC);
    Kalm.encoders.register('msg-pack', msgpack);

    var server = new Kalm.Server({
      port: 3000,
      adapter: 'webrtc',
      encoder: 'msg-pack'

Run tests

npm test


Kalm uses debug

export DEBUG=kalm

You can also gather optimization statistics by piping kalm:stats

export DEBUG=kalm:stats myApp.js > stats.log




Top Contributors

fed135 joesonw


package version
dev chai ^3.5.0
mocha ^3.2.0
sinon ^1.17.0
bsplit 1.0.x
debug 2.6.x


-   v1.3.0 zip tar
-   v1.2.0 zip tar
-   v1.1.1 zip tar
-   v1.0.4 zip tar
-   v1.0.3 zip tar
-   v1.0.2 zip tar
-   v1.0.1 zip tar
-   v1.0.0 zip tar
-   v0.3.0 zip tar
-   v0.2.0 zip tar
-   v0.1.2 zip tar
-   v0.1.0 zip tar