Switch to using 'spare_buffer' crate.

Cargo.toml

@@ -3,7 +3,7 @@
 
 [package]
 name = "mtcp-rs"
-version = "0.1.9"
+version = "0.1.10"
 edition = "2021"
 license-file = "LICENSE"
 description = "Provides a “blocking” implementation of TcpListener and TcpStream with proper timeout and cancellation support."
@@ -16,6 +16,7 @@ readme = "README.md"
 lazy_rc = "0.1.3"
 log = "0.4.17"
 mio = { version = "0.8.5", features = ["os-poll", "net"] }
+spare_buffer = "0.1.0"
 
 [dev-dependencies]
 crossbeam-channel = "0.5.6"

src/stream.rs

@@ -13,8 +13,9 @@ use mio::{Token, Interest};
 use mio::net::TcpStream as MioTcpStream;
 
 use log::warn;
+use spare_buffer::SpareBuffer;
 
-use crate::utilities::{Timeout, BufferManager};
+use crate::utilities::Timeout;
 use crate::{TcpConnection, TcpManager, TcpError};
 use crate::manager::TcpPollContext;
 
@@ -288,15 +289,15 @@ impl TcpStream {
             panic!("maximum_length must be greater than or equal to chunk_size!")
         }
 
-        let mut buffer = BufferManager::from(buffer, maximum_length);
+        let mut buffer = SpareBuffer::from(buffer, maximum_length);
 
         loop {
-            let spare = buffer.alloc_spare_buffer(chunk_size);
+            let spare = buffer.allocate_spare(chunk_size);
             match self.read_timeout(spare, timeout) {
                 Ok(0) => return Err(TcpError::Incomplete),
                 Ok(count) => {
                     buffer.commit(count).map_err(|_err| TcpError::TooBig)?;
-                    match fn_complete(buffer.valid_data()) {
+                    match fn_complete(buffer.data()) {
                         true => return Ok(()),
                         false => {},
                     }

src/utilities/mod.rs

@@ -3,9 +3,7 @@
  * This is free and unencumbered software released into the public domain.
  */
 mod flag;
-mod buffer;
 mod timeout;
 
-pub(crate) use buffer::BufferManager;
 pub(crate) use flag::Flag;
 pub(crate) use timeout::Timeout;