Bi-direction event emitter over a stream