Skip to main content

copy_worker_data_plane_payload

rustferry_remote::data_plane

Function copy_worker_data_plane_payload 

Source 
pub fn copy_worker_data_plane_payload(
    reader: &mut impl Read,
    writer: &mut impl Write,
    header: WorkerDataPlaneFrameHeader,
) -> Result<u64, WorkerDataPlaneFrameError>
Expand description

Stream exactly one validated payload into a sink with constant memory.

ยงErrors

Returns WorkerDataPlaneFrameError::TruncatedPayload if input ends before the declared length, or a stable I/O error if reading or writing otherwise fails.