risingwave_connector::source::test_source

Function registry_test_source

source 
pub fn registry_test_source(box_source: BoxSource) -> TestSourceRegistryGuard