Sha256: c19e44f7b9fe275f38b12fc2a139cf64310400534480a2151160d5b2a862468b
Contents?: true
Size: 464 Bytes
Versions: 33
Compression:
Stored size: 464 Bytes
Contents
'use strict';
var freemem = require('os').freemem;
var codec = require('../codec');
var id = Math.random();
var recv = 0;
var sub = require('redis').createClient()
.on('ready', function() {
this.subscribe('timeline');
})
.on('message', function(channel, message) {
var self = this;
if (message) {
message = codec.decode(message);
++recv;
}
});
setInterval(function() {
console.error('id', id, 'received', recv, 'free', freemem());
}, 2000);
Version data entries
33 entries across 33 versions & 4 rubygems