Overhaul of buffer representation

examples/cat.rs

@@ -22,7 +22,7 @@ fn main() {
     tokio_uring::start(async {
         // Open the file without blocking
         let file = File::open(path).await.unwrap();
-        let mut buf = vec![0; 16 * 1_024];
+        let mut buf = vec![0; 16 * 1_024].into();
 
         // Track the current position in the file;
         let mut pos = 0;
@@ -34,7 +34,7 @@ fn main() {
                 break;
             }
 
-            out.write_all(&b[..n]).unwrap();
+            out.write_all(&b[0][..n]).unwrap();
             pos += n as u64;
 
             buf = b;

examples/mix.rs

@@ -27,19 +27,14 @@ fn main() {
             tokio_uring::spawn(async move {
                 // Open the file without blocking
                 let file = File::open(path).await.unwrap();
-                let mut buf = vec![0; 16 * 1_024];
+                let mut buf = vec![0; 16 * 1_024].into();
 
                 // Track the current position in the file;
                 let mut pos = 0;
 
                 loop {
                     // Read a chunk
-<<<<<<< HEAD
-                    let (res, b) = file.read_at(buf, pos).submit().await;
-                    let n = res.unwrap();
-=======
-                    let (n, b) = file.read_at(buf, pos).await.unwrap();
->>>>>>> 6b5865f (Refresh: Update Result<T, B> to be Result<(T,B), Error<B>)
+                    let (n, b) = file.read_at(buf, pos).submit().await.unwrap();
 
                     if n == 0 {
                         break;

examples/tcp_stream.rs

@@ -13,12 +13,12 @@ fn main() {
 
     tokio_uring::start(async {
         let stream = TcpStream::connect(socket_addr).await.unwrap();
-        let buf = vec![1u8; 128];
+        let buf = vec![1u8; 128].into();
 
         let (n, buf) = stream.write(buf).submit().await.unwrap();
         println!("written: {}", n);
 
         let (read, buf) = stream.read(buf).await.unwrap();
-        println!("read: {:?}", &buf[..read]);
+        println!("read: {:?}", &buf[0][..read]);
     });
 }

examples/unix_listener.rs

@@ -18,13 +18,13 @@ fn main() {
             let stream = listener.accept().await.unwrap();
             let socket_addr = socket_addr.clone();
             tokio_uring::spawn(async move {
-                let buf = vec![1u8; 128];
+                let buf = vec![1u8; 128].into();
 
                 let (n, buf) = stream.write(buf).submit().await.unwrap();
                 println!("written to {}: {}", &socket_addr, n);
 
                 let (read, buf) = stream.read(buf).await.unwrap();
-                println!("read from {}: {:?}", &socket_addr, &buf[..read]);
+                println!("read from {}: {:?}", &socket_addr, &buf[0][..read]);
             });
         }
     });

examples/unix_stream.rs

@@ -13,12 +13,12 @@ fn main() {
 
     tokio_uring::start(async {
         let stream = UnixStream::connect(socket_addr).await.unwrap();
-        let buf = vec![1u8; 128];
+        let buf = vec![1u8; 128].into();
 
         let (n, buf) = stream.write(buf).submit().await.unwrap();
         println!("written: {}", n);
 
         let (read, buf) = stream.read(buf).await.unwrap();
-        println!("read: {:?}", &buf[..read]);
+        println!("read: {:?}", &buf[0][..read]);
     });
 }

examples/wrk-bench.rs

@@ -22,7 +22,7 @@ fn main() -> io::Result<()> {
                     let (stream, _) = listener.accept().await?;
 
                     tokio_uring::spawn(async move {
-                        let result = stream.write(RESPONSE).submit().await;
+                        let result = stream.write(RESPONSE.to_vec().into()).submit().await;
                         if let Err(err) = result {
                             eprintln!("Client connection failed: {}", err);
                         }

src/buf/fixed/pool.rs

@@ -55,7 +55,7 @@ use std::sync::Arc;
 ///
 /// # Examples
 ///
-/// ```
+/// ```no_compile
 /// use tokio_uring::buf::fixed::FixedBufPool;
 /// use tokio_uring::buf::IoBuf;
 /// use std::iter;