Added stream end emitter