chore: release 0.0.7

bach/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bach"
-version = "0.0.6"
+version = "0.0.7"
 authors = ["Cameron Bytheway <[email protected]>"]
 description = "Discrete-event simulation environment for async workflows"
 repository = "https://github.com/camshaft/bach"

bach/src/net.rs

@@ -1 +1 @@
-pub use std::net::{SocketAddr, SocketAddrV4, SocketAddrV6};
+pub use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr, SocketAddrV4, SocketAddrV6};

bach/src/sync/queue.rs

@@ -1,6 +1,6 @@
 use crate::{sync::channel, time::Instant};
 use core::fmt;
-use std::task::Context;
+use std::{sync::Arc, task::Context};
 
 pub mod latent;
 pub mod priority;
@@ -23,6 +23,51 @@ pub trait Queue<T> {
     fn capacity(&self) -> Option<usize>;
 }
 
+impl<T, Q> Queue<T> for Arc<Q>
+where
+    Q: Queue<T>,
+{
+    fn push(&self, value: T) -> Result<Option<T>, PushError<T>> {
+        self.as_ref().push(value)
+    }
+
+    fn push_with_context(&self, value: T, cx: &mut Context) -> Result<Option<T>, PushError<T>> {
+        self.as_ref().push_with_context(value, cx)
+    }
+
+    fn pop(&self) -> Result<T, PopError> {
+        self.as_ref().pop()
+    }
+
+    fn pop_with_context(&self, cx: &mut Context) -> Result<T, PopError> {
+        self.as_ref().pop_with_context(cx)
+    }
+
+    fn close(&self) -> Result<(), CloseError> {
+        self.as_ref().close()
+    }
+
+    fn is_closed(&self) -> bool {
+        self.as_ref().is_closed()
+    }
+
+    fn is_empty(&self) -> bool {
+        self.as_ref().is_empty()
+    }
+
+    fn is_full(&self) -> bool {
+        self.as_ref().is_full()
+    }
+
+    fn len(&self) -> usize {
+        self.as_ref().len()
+    }
+
+    fn capacity(&self) -> Option<usize> {
+        self.as_ref().capacity()
+    }
+}
+
 pub trait Conditional<T>: Queue<T> {
     fn find_pop<F: Fn(&T) -> bool>(&self, check: F) -> Result<T, PopError>;
 }