could simplify it to con.pipe(ree.getStream()).pipe(con)