don't emit end event in stream code
use through2 stream