es-writable-stream-2.js

const stream = require('stream')
const elasticsearch = require('elasticsearch')

class ElasticSearchWritableStream extends stream.Writable {
  constructor(config) {
    super()
    this.config = config
    
    /**
     * Create the ElasticSearch client:
     */

    this.client = new elasticsearch.Client({
      host: this.config.host
    })
  }
}

module.exports = ElasticSearchWritableStream