Function test_complete_data_flow 

pub(crate) async fn test_complete_data_flow(
    rx: &mut UnboundedReceiver<DataEvent>,
) -> Result<()>