WIP: Add unix socket support?

Cargo.toml

@@ -18,10 +18,11 @@ maintenance = { status = "actively-developed" }
 all-features = true
 
 [features]
-default = ["tcp", "udp", "websocket"] # All features by default
+default = ["tcp", "udp", "websocket"] # All features that are crossplatform by default
 tcp = ["mio/net", "socket2"]
 udp = ["mio/net", "socket2"]
 websocket = ["tungstenite", "url", "tcp"]
+unixsocket = ["mio/net", "socket2"] # TODO: check if this is really needed
 
 [dependencies]
 mio = { version = "0.8", features = ["os-poll"] }

examples/throughput/main.rs

@@ -25,6 +25,11 @@
     throughput_message_io(Transport::Tcp, CHUNK);
     throughput_message_io(Transport::FramedTcp, CHUNK);
     throughput_message_io(Transport::Ws, CHUNK);
+    // for platforms that support it
+    #[cfg(feature = "unixsocket")]
+    throughput_message_io(Transport::UnixSocketStream, CHUNK);
+    #[cfg(feature = "unixsocket")]
+    throughput_message_io(Transport::UnixSocketDatagram, CHUNK);
     println!();
     throughput_native_udp(CHUNK);
     throughput_native_tcp(CHUNK);
@@ -234,7 +239,7 @@
                 let (mut sender, _) = ws_connect(Url::parse(&url_addr).unwrap()).unwrap();
                 let start_time = Instant::now();
                 while total_sent < EXPECTED_BYTES {
                     sender.write_message(Message::Binary(message.clone())).unwrap();
                     total_sent += message.len();
                 }
                 start_time
@@ -245,7 +250,7 @@
     let mut receiver = ws_accept(listener.accept().unwrap().0).unwrap();
     let mut total_received = 0;
     while total_received < EXPECTED_BYTES {
         total_received += receiver.read_message().unwrap().len();
     }
     let end_time = Instant::now();
 

src/adapters.rs

@@ -8,5 +8,7 @@ pub mod framed_tcp;
 pub mod udp;
 #[cfg(feature = "websocket")]
 pub mod ws;
+#[cfg(feature = "unixsocket" )]
+pub mod unix_socket;
 // Add new adapters here
-// ...
+// ...