var elasticstream = require('elasticstream'),
    stream = elasticstream({ index: 'twitter', type: 'user'});

stream.write({
  id: 'maciejmalecki',
  doc: {
    name: 'Maciej Malecki'
  }
});
stream.end();