Skip to main content

stream_distributed_read

Function stream_distributed_read 

Source
pub async fn stream_distributed_read(
    __arg0: Extension<Arc<ServerState>>,
    __arg1: Extension<RequestContext>,
    __arg2: Path<String>,
) -> Response
Expand description

Stream an already prepared distributed result. A coordinator registers the execution before dispatch and calls publish_prepared only after every range has supplied its P2.10 cleanup acknowledgement through P2.11.