try fanout

index.js

@@ -12,26 +12,40 @@ module.exports = function (cb) {
   var server = http.createServer(ecstatic({ root: path.join(__dirname, 'public') }))
   var sse = SSE('/data')
   var header
+
+  var clients = []
+
+  input.on('data', function(data){
+      for(var c in clients) {
+          clients[c].write(data);
+      }
+  })
 
   sse.install(server)
 
     console.log('init chart-stream')
 
     /// TODO MANUALLY MANAGE CONENCTED CLIENTS AND SEND THEM INPUT > FANOUT
 
-
   sse.on('connection', function (client) {
       console.log('client connection...')
-
+      var cx = clients.push(client) - 1
       if(header) client.write(header);
 
-      setTimeout(function(){
-          console.log('client connection pump starting..')
-        pump(input, client);
-        client.on('close', function(){
-            console.log('client closed')
-        })
-      },5000)
+      client.on('close', function(){
+        console.log('client closed. remove from clients list len: '+clients.length)
+        clients.splice(cx, 1);
+        console.log('client closed. removed from clients list len: '+clients.length)
+    })
+
+
+    //   setTimeout(function(){
+    //       console.log('client connection pump starting..')
+    //     pump(input, client);
+    //     client.on('close', function(){
+    //         console.log('client closed')
+    //     })
+    //   },5000)
 
     // input.once('data', function (chunk) {
     //     // console.log('input data')

public/index.html

@@ -14,8 +14,8 @@
     #graph {
       height: 100vh;
     }
-    path {
-        stroke-width: 4px;
+    path, path.c3-line {
+        stroke-width: 3px;
     }
   </style>
 </head>