es.map doesn't fire 'end' event?

[kevzettler]

I have a stream thats piped to es.map and it dosen't seem to fire end close or finish below is the map function.

function installFilterDataHandle(install, cb){
  var install_obj = JSON.parse(install);
  var origin_key = key_map[install_obj.api_key];

  if(!_.isUndefined(origin_key)){
    idfa_map[origin_key] = install_obj.om_idfa;
    cb(null,null);
  }
  cb(null, null);
}


  install_pipe = install_filter.stdout
              .pipe(es.split())
              .pipe(es.map(installFilterDataHandle));

  install_pipe.on('data', function(data){
    console.log("install pipe data",data);
  });

  install_pipe.on('end', function(){
    console.log('done mapping installs');
  });

  install_pipe.on('close', function(){
    console.log('done mapping installs');
  });

  install_pipe.on('finish', function(){
    console.log('done mapping installs');
  });

[dominictarr]

you are calling the cb twice (once inside the if and then after it) I wouldn't be surprised if you that breaks something - also: are you sure that install_filter is emitting end?

[kevzettler]

@dominictarr the install_filter is actually a child process grep I don't explicitly kill the child process is that prohibiting it from sending the end event?

[dominictarr]

well, the child process decides when to exit. it may also depend on the input to grep.
I doubt that the problem is map because loads of people have used event-stream for ages and no one has compliained about this. I'd add an install_filter.on('end', ...) and some logging because that is my bet.