Merge pull request #15 from Rayzeq/master

Permit making blocking sockets

src/lib.rs

@@ -12,7 +12,10 @@ mod unix;
 pub use unix::*;
 
 pub struct MulticastOptions {
-    pub read_timeout: Duration,
+    /// The maximal timeout before [`MulticastSocket::receive`] returns.
+    ///
+    /// If this is `None`, [`MulticastSocket::receive`] will block until there is data to read.
+    pub read_timeout: Option<Duration>,
     pub loopback: bool,
     pub buffer_size: usize,
     /// The address to bind the socket to.
@@ -25,7 +28,7 @@ pub struct MulticastOptions {
 impl Default for MulticastOptions {
     fn default() -> Self {
         MulticastOptions {
-            read_timeout: Duration::from_secs(1),
+            read_timeout: Some(Duration::from_secs(1)),
             loopback: true,
             buffer_size: 512,
             bind_address: Ipv4Addr::UNSPECIFIED,

src/unix.rs

@@ -15,7 +15,7 @@ fn create_on_interfaces(
     multicast_address: SocketAddrV4,
 ) -> io::Result<MulticastSocket> {
     let socket = Socket::new(Domain::ipv4(), Type::dgram(), Some(Protocol::udp()))?;
-    socket.set_read_timeout(Some(options.read_timeout))?;
+    socket.set_read_timeout(options.read_timeout)?;
     socket.set_multicast_loop_v4(options.loopback)?;
     socket.set_reuse_address(true)?;
     socket.set_reuse_port(true)?;

src/win.rs

@@ -141,7 +141,7 @@ fn create_on_interfaces(
     multicast_address: SocketAddrV4,
 ) -> io::Result<MulticastSocket> {
     let socket = Socket::new(Domain::ipv4(), Type::dgram(), Some(Protocol::udp()))?;
-    socket.set_read_timeout(Some(options.read_timeout))?;
+    socket.set_read_timeout(options.read_timeout)?;
     socket.set_multicast_loop_v4(options.loopback)?;
     socket.set_reuse_address(true)?;