Socket.io-Stream не отправляет клиенту

Я пытаюсь отправить (ретранслировать) непрерывный поток данных utf-8 с сервера на клиент. Хотя я могу наблюдать за данными, поступающими на сервер, я не могу передать его в Socket и переслать его клиенту.

Сервер Nodejs,

var io = require('socket.io')(server);
app.io = io;
var dsteem = require('dsteem')
var es = require('event-stream') 
var client = new dsteem.Client('https://api.steemit.com')
var ss = require('socket.io-stream'); 
var outBoundStream = ss.createStream();
var stream = client.blockchain.getBlockStream();

io.on('connection', function(socket) {
    /* Eyeball the data in the nodejs console */ 
    stream.pipe(es.map(function(block, callback) {
    callback(null, util.inspect(block, {colors: true, depth: null}) + '\n')
    })).pipe(process.stdout);
    /* Send stream data to client */
    ss(socket).on('ready', function(){
        console.log('Here it comes...');
        ss(socket).emit('sending', function(){
            stream.pipe(es.map(function(block, callback) {
            callback(null, util.inspect(block, {colors: true, depth: null}) + '\n')
            }));
        });
    });

    ss(socket).on('disconnect', function(){
        console.log('Disconnected');
    });
});

Данные из .getBlockStream(), которые я вижу в консоли nodejs, выглядят как-то вроде этого snip,

 {['1b3c0394d1146cecdc0b5d38486f0b99a6d7c750',
 '85e3110930f87510b4782d50de86180ecbacf05d',
 '7cbd01b2a9d515736860014eabbc18893707e0c4',
 '307308574fec6336493d0a9713ee98da21bbc1a7',
 '9cb1636cdb2591361b7d7e4c9d04096c1bc93aff',
 '27d22c51a6f3e0d764039b095046ec563e53ae6b',
 '153451e251816823e3342d2f0b1425570d0f3d36',
 '0a17b03e9fddfde49ad632dfe2437d76321c34eb',
 'fdd23d78865d1855b16d171d24199dd4e2fba83a',
 '306e6f2b11e6bd6e2ef37acbe6e593ef2d1c0e1e' ] }

клиент,

<script src="/socket.io/socket.io.js"></script>
<script src="/javascripts/socket.io-stream.js"></script>
<script> 
$(function () {
    var socket = io();
    ss(socket).emit('ready', 'Client ready, send me a stream...');
    ss(socket).on('sending', function(stream, d){
            console.log(stream);
  });
});
</script>

В консоли браузера я вижу только эту функцию,

ƒ () {
        var args = slice.call(arguments);
        args = self.encoder.encode(args);
        ack.apply(this, args);
      }

Может кто-нибудь помочь мне понять, что я делаю неправильно?

Ответ 1