re_grpc_client::redap

Function stream_partition_async

Source 
pub async fn stream_partition_async(
    tx: Sender<LogMsg>,
    uri: DatasetDataUri,
    on_cmd: Box<dyn Fn(Command) + Send + Sync>,
    on_msg: Option<Box<dyn Fn() + Send + Sync>>,
) -> Result<(), StreamError>