Start of async TCP

Author: QuantumEntangledAndy

Cargo.lock

@@ -22,6 +22,7 @@ rand = "0.8.4"
 regex = "1.5.4"
 socket2 = "0.3"
 time = "0.2"
+tokio = { version = "1.24.2", features = ["full"] }
 xml-rs = "0.8"
 yaserde = "0.3.16"
 yaserde_derive = "0.3.16"

crates/core/Cargo.toml

@@ -13,14 +13,14 @@ use time::OffsetDateTime;
 type IResult<I, O, E = nom::error::VerboseError<I>> = Result<(I, O), nom::Err<E>>;
 
 /// The error types used during deserialisation
-#[derive(Debug, Error)]
+#[derive(Debug, Error, Clone)]
 pub enum Error {
     /// A Nom parsing error usually a malformed packet
     #[error(display = "Parsing error: {}", _0)]
     NomError(String),
     /// An IO error such as the stream being dropped
     #[error(display = "I/O error")]
-    IoError(#[error(source)] std::io::Error),
+    IoError(#[error(source)] std::sync::Arc<std::io::Error>),
 }
 type NomErrorType<'a> = nom::error::VerboseError<&'a [u8]>;
 
@@ -35,6 +35,12 @@ impl<'a> From<nom::Err<NomErrorType<'a>>> for Error {
     }
 }
 
+impl From<std::io::Error> for Error {
+    fn from(k: std::io::Error) -> Self {
+        Error::IoError(std::sync::Arc::new(k))
+    }
+}
+
 fn read_from_reader<P, O, E, R>(mut parser: P, mut rdr: R) -> Result<O, E>
 where
     R: Read,