Method read

src/ore/src/bytes.rs:328–356

(&mut self, buf: &mut [u8])

    impl<const N: usize> io::Read for SegmentedReader<N> {
        fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
            // We've seeked past the end, return nothing.
            if self.overall_ptr >= self.len {
                return Ok(0);
            }

            let (segment, accum_length) = &self.segments[self.segment_ptr];

            // How many bytes we have left in this segment.
            let remaining_len = accum_length.checked_sub(self.overall_ptr).unwrap();
            // Position within the segment to begin reading.
            let segment_pos = segment.len().checked_sub(remaining_len).unwrap();

            // How many bytes we'll read.
            let len = core::cmp::min(remaining_len, buf.len());
            // Copy bytes from the current segment into the buffer.
            let segment_buf = &segment[..];
            buf[..len].copy_from_slice(&segment_buf[segment_pos..segment_pos + len]);

            // Advance our pointers.
            self.overall_ptr += len;

            // Advance to the next segment if we've reached the end of the current.
            if self.overall_ptr == *accum_length {
                self.segment_ptr += 1;
            }

            Ok(len)
        }
    }

    impl<const N: usize> io::Seek for SegmentedReader<N> {