Skip to main content

respond_stream_with_deadlines

Function respond_stream_with_deadlines 

Source
pub fn respond_stream_with_deadlines(
    socket: &impl AsFd,
    repository: &impl Repository,
    encoder: &mut ResponseEncoder<'_>,
    staging: &mut [u8],
    deadlines: ResponseDeadlines,
) -> Result<()>
Expand description

Bound an entire streamed response and gaps in successful socket writes. Clock checks bracket every synchronous provider pull and EOF; a blocking provider cannot be preempted. Any expiry cancels the response without a successful protocol terminator. Close the transport on every error.