register_test_source

risingwave_connector::source::test_source

Function register_test_source 

Source 
pub fn register_test_source(box_source: BoxSource) -> TestSourceRegistryGuard