Function data_events 

pub fn data_events<T, Mat>(source: Source<T, Mat>) -> Source<SqlEvent<T>, Mat>
where
    T: Send + 'static,
    Mat: Send + 'static,

Wraps every payload from a source as SqlEvent::Data.