Function map_data_expr 

pub fn map_data_expr<F>(source: Stream, f: F) -> Stream
where
    F: Fn(Expr) -> Result<Expr> + Send + Sync + 'static,

Returns a stream that rewrites each data packet’s payload expression with f.

Non-data packets pass through untouched.