dispatching_future

risingwave_stream::executor::dispatch::dispatch_sync_log_store

Function dispatching_future 

Source 
fn dispatching_future(
    inner: DispatchExecutorInner,
    message: Message,
) -> impl Future<Output = (DispatchExecutorInner, StreamResult<Option<Barrier>>)> + 'static