Pipelet: emit_xxx(), emit "complete" event when no more events are expected