@sio.on('json')
def handle_message(cluster):
  if cluster:
    a = EC_STREAMS()
    cluster_arn_stream = Observable.timer(0, CLUSTER_ARN_REFRESH_INTERVAL * 60000)
      .from_(a.fetch_cluster_info(clusters=[cluster]))
      .subscribe(
        on_next=lambda  value: sio.emit('json', value),
        on_error=lambda err:   sio.emit('json',  {'error': err})
      )
  print('received cluster: ' + cluster)

const io = require('socket.io-client');

    socket = io.connect('ws://127.0.0.1:5000', {
      path: '/stream',
      transports: ['websocket']
    });

socket.on('connect',() => {
  console.log("Connected!");
  socket.on('json', (data) => {
    console.log(data);
  });
});

socket.emit('json', 'my-ecs-cluster');