refactor: rename read_header to find_message_head_end

Author: darkseid-is

Cargo.lock

@@ -9,7 +9,7 @@ use crate::body_struct::ChunkedBody;
 use super::content_length_reader::read_content_length;
 use header_plz::abnf::CRLF;
 use header_plz::header_map::HeaderMap;
-use header_plz::reader::read_header;
+use header_plz::reader::find_message_head_end;
 
 // Enum to represent chunked reader errors
 #[cfg_attr(any(debug_assertions, test), derive(Eq, PartialEq))]
@@ -124,7 +124,7 @@ impl ChunkReader {
                     return Some(ChunkedBody::EndCRLF(buf.split_at_current_pos()));
                 }
                 // 4.b. Actual Headers
-                if read_header(buf) {
+                if find_message_head_end(buf) {
                     *self = Self::End;
                     let header_map = HeaderMap::new(buf.split_at_current_pos());
                     Some(ChunkedBody::Trailers(header_map))

body-plz/src/reader/chunked_reader.rs

@@ -10,7 +10,7 @@ use crate::abnf::HEADER_DELIMITER;
  *         false.
  */
 
-pub fn read_header(buf: &mut Cursor) -> bool {
+pub fn find_message_head_end(buf: &mut Cursor) -> bool {
     // 1. Find HEADER_DELIMITER
     if let Some(index) = buf
         .as_ref()
@@ -41,7 +41,7 @@ mod tests {
         let mut buf = BytesMut::from(req);
         let mut cur = Cursor::new(&mut buf);
         let verify = BytesMut::from(req);
-        let status: bool = read_header(&mut cur);
+        let status: bool = find_message_head_end(&mut cur);
         assert!(status);
         assert_eq!(cur.position(), verify.len());
     }
@@ -52,7 +52,7 @@ mod tests {
                     Host: reqbin.com\r\n";
         let mut buf = BytesMut::from(req);
         let mut cur = Cursor::new(&mut buf);
-        let status: bool = read_header(&mut cur);
+        let status: bool = find_message_head_end(&mut cur);
         assert!(!status);
         assert_eq!(cur.position(), req.len() - 3);
     }
@@ -62,17 +62,17 @@ mod tests {
         let req = "GET /echo HTTP/1.1\r\n";
         let mut buf = BytesMut::from(req);
         let mut cur = Cursor::new(&mut buf);
-        let mut status = read_header(&mut cur);
+        let mut status = find_message_head_end(&mut cur);
         assert!(!status);
         assert_eq!(cur.position(), req.len() - 3);
         let toadd = b"Host: reqbin.com\r";
         cur.as_mut().extend_from_slice(toadd);
-        status = read_header(&mut cur);
+        status = find_message_head_end(&mut cur);
         assert!(!status);
         assert_eq!(cur.position(), cur.as_ref().len() - 3);
         let toadd = b"\n\r\n";
         cur.as_mut().extend_from_slice(toadd);
-        status = read_header(&mut cur);
+        status = find_message_head_end(&mut cur);
         assert!(status);
         assert_eq!(cur.position(), cur.as_ref().len());
     }