readfilestream.coffee

fs = require 'fs'
noflo = require 'noflo'
split = require 'split'

class ReadFileStream extends noflo.Component
  constructor: ->
    @inPorts =
      in: new noflo.Port()
    @outPorts =
      out: new noflo.Port()
      error: new noflo.Port()

    @inPorts.in.on 'data', (data) =>
      @readStream = fs.createReadStream(data, encoding: 'utf-8')

      @readStream.pipe(split()).on 'data', (line) =>
        @outPorts.out.send line

      @readStream.on 'end', =>
        @outPorts.out.disconnect()
    
exports.getComponent = -> new ReadFileStream