Started BufferedEsock: A task-based ``wrapper" around an ESock that buffers its input and output.

Fortune for rsh's current commit: Small blessing − 小吉

Cargo.toml

@@ -17,7 +17,7 @@ mopa = "0.2.2"
 pin-project = "1.0.8"
 serde = { version = "1.0.126", features = ["derive"] }
 serde_cbor = "0.11.1"
-smallvec = { version = "1.6.1", features = ["union", "serde", "write"] }
+smallvec = { version = "1.6.1", features = ["union", "serde", "write", "const_generics"] }
 stackalloc = "1.1.1"
 tokio = { version = "0.2", features = ["full"] }
 tokio-uring = "0.1.0"

src/sock/mod.rs

@@ -19,6 +19,7 @@ use bytes::Bytes;
 use cancel::*;
 
 pub mod enc;
+pub mod pipe;
 
 /// Details of a newly accepted raw socket peer.
 ///

src/sock/pipe.rs

@@ -0,0 +1,53 @@
+//! Piping buffered data from a raw socket to `ESock`
+//!
+//! This exists because i'm too dumb to implement a functional AsyncRead/Write buffered wrapper stream :/
+use super::*;
+use std::{
+    io,
+    marker::{
+	Send, Sync,
+	
+	Unpin,
+	PhantomData,
+    },
+};
+use tokio::sync::{
+    mpsc,
+};
+use enc::{
+    ESock,
+    
+    ESockReadHalf,
+    ESockWriteHalf,
+};
+
+/// The default buffer size for `BufferedESock`.
+pub const DEFAULT_BUFFER_SIZE: usize = 32;
+
+/// Task-based buffered piping to/from encrypted sockets.
+pub struct BufferedESock<W, R>
+{
+    bufsz: usize,
+    _backing: PhantomData<ESock<W, R>>,
+}
+
+impl<W, R> BufferedESock<W, R>
+where W: AsyncWrite + Unpin + Send + 'static,
+      R: AsyncRead + Unpin + Send + 'static
+{
+    /// Create a new buffered ESock pipe with a specific buffer size
+    pub fn with_size(tx: W, rx: R, bufsz: usize) -> Self
+    {
+	//TODO: Spawn read+write buffer tasks
+	Self {
+	    bufsz,
+	    _backing: PhantomData,
+	}
+    }
+
+    /// Create a new buffered ESock pipe with the default buffer size (`DEFAULT_BUFFER_SIZE`).
+    #[inline] pub fn new(tx: W, rx: R) -> Self
+    {
+	Self::with_size(tx, rx, DEFAULT_BUFFER_SIZE)
+    }
+}