style: deny unreachable_pub

Author: paolobarbolini

src/instant.rs

@@ -4,28 +4,28 @@ use std::{
 };
 
 #[derive(Debug, Clone)]
-pub struct ReferenceInstant {
+pub(crate) struct ReferenceInstant {
     #[cfg(not(feature = "strong"))]
     instant: Instant,
 }
 
 #[derive(Debug, Copy, Clone)]
-pub struct RelativeInstant {
+pub(crate) struct RelativeInstant {
     #[cfg(feature = "strong")]
     relative: Instant,
     #[cfg(not(feature = "strong"))]
     relative: Duration,
 }
 
 impl ReferenceInstant {
-    pub fn new() -> Self {
+    pub(crate) fn new() -> Self {
         Self {
             #[cfg(not(feature = "strong"))]
             instant: Instant::now(),
         }
     }
 
-    pub fn now(&self) -> RelativeInstant {
+    pub(crate) fn now(&self) -> RelativeInstant {
         RelativeInstant {
             #[cfg(feature = "strong")]
             relative: Instant::now(),
@@ -37,10 +37,10 @@ impl ReferenceInstant {
 
 impl RelativeInstant {
     #[cfg(not(feature = "strong"))]
-    pub const ENCODED_LEN: usize = 12;
+    pub(crate) const ENCODED_LEN: usize = 12;
 
     #[cfg(not(feature = "strong"))]
-    pub fn encode(&self) -> [u8; Self::ENCODED_LEN] {
+    pub(crate) fn encode(&self) -> [u8; Self::ENCODED_LEN] {
         let mut buf = [0u8; Self::ENCODED_LEN];
         let (secs, nanos) = buf.split_at_mut(8);
         secs.copy_from_slice(&self.relative.as_secs().to_ne_bytes());
@@ -50,7 +50,7 @@ impl RelativeInstant {
     }
 
     #[cfg(not(feature = "strong"))]
-    pub fn decode(buf: &[u8; Self::ENCODED_LEN]) -> Option<Self> {
+    pub(crate) fn decode(buf: &[u8; Self::ENCODED_LEN]) -> Option<Self> {
         let (secs, nanos) = buf.split_at(8);
         let secs = u64::from_ne_bytes(secs.try_into().unwrap());
         let nanos = u32::from_ne_bytes(nanos.try_into().unwrap());

src/lib.rs

@@ -24,6 +24,7 @@
 
 #![deny(
     rust_2018_idioms,
+    unreachable_pub,
     clippy::doc_markdown,
     rustdoc::broken_intra_doc_links
 )]

src/socket/base.rs

@@ -11,12 +11,12 @@ use socket2::{Domain, Protocol, SockAddr, Type};
 
 use crate::IpVersion;
 
-pub struct BaseSocket {
+pub(crate) struct BaseSocket {
     socket: socket2::Socket,
 }
 
 impl BaseSocket {
-    pub fn new_icmp<V: IpVersion>(
+    pub(crate) fn new_icmp<V: IpVersion>(
         blocking: bool,
         read_timeout: Option<Duration>,
     ) -> io::Result<Self> {
@@ -43,7 +43,7 @@ impl BaseSocket {
         socket2::Socket::new(Domain::IPV6, Type::RAW, Some(Protocol::ICMPV6))
     }
 
-    pub fn recv(&self, buf: &mut [MaybeUninit<u8>]) -> io::Result<(&'_ [u8], SocketAddr)> {
+    pub(crate) fn recv(&self, buf: &mut [MaybeUninit<u8>]) -> io::Result<(&'_ [u8], SocketAddr)> {
         self.socket.recv_from(buf).map(|(filled, source)| {
             (
                 unsafe { slice::from_raw_parts(buf.as_ptr().cast::<u8>(), filled) },
@@ -52,7 +52,7 @@ impl BaseSocket {
         })
     }
 
-    pub fn send_to(&self, buf: &[u8], addr: SocketAddr) -> io::Result<usize> {
+    pub(crate) fn send_to(&self, buf: &[u8], addr: SocketAddr) -> io::Result<usize> {
         let addr = SockAddr::from(addr);
 
         self.socket.send_to(buf, &addr)

src/socket/mod.rs

@@ -7,24 +7,24 @@ use std::{
 
 use tokio::io::unix::AsyncFd;
 
-pub use self::base::BaseSocket;
+pub(crate) use self::base::BaseSocket;
 use crate::IpVersion;
 
 mod base;
 
-pub struct Socket {
+pub(crate) struct Socket {
     fd: AsyncFd<BaseSocket>,
 }
 
 impl Socket {
-    pub fn new_icmp<V: IpVersion>() -> io::Result<Self> {
+    pub(crate) fn new_icmp<V: IpVersion>() -> io::Result<Self> {
         let base = BaseSocket::new_icmp::<V>(false, None)?;
 
         let fd = AsyncFd::new(base)?;
         Ok(Self { fd })
     }
 
-    pub fn poll_read(
+    pub(crate) fn poll_read(
         &self,
         cx: &mut Context<'_>,
         buf: &mut [MaybeUninit<u8>],
@@ -40,7 +40,7 @@ impl Socket {
         }
     }
 
-    pub fn poll_write_to(
+    pub(crate) fn poll_write_to(
         &self,
         cx: &mut Context<'_>,
         buf: &[u8],