diff --git a/src/connection/mod.rs b/src/connection/mod.rs
index 10dacbe976..7aa4ab78ec 100644
--- a/src/connection/mod.rs
+++ b/src/connection/mod.rs
@@ -102,3 +102,19 @@ pub fn connect<M: Message>(address: &str) -> io::Result<Box<dyn MavConnection<M>
         protocol_err
     }
 }
+
+/// Returns the socket address for the given address.
+pub(crate) fn get_socket_addr<T: std::net::ToSocketAddrs>(
+    address: T,
+) -> Result<std::net::SocketAddr, io::Error> {
+    let addr = match address.to_socket_addrs()?.next() {
+        Some(addr) => addr,
+        None => {
+            return Err(io::Error::new(
+                io::ErrorKind::Other,
+                "Host address lookup failed",
+            ));
+        }
+    };
+    Ok(addr)
+}
diff --git a/src/connection/tcp.rs b/src/connection/tcp.rs
index 7f4f7eaf8e..b34eb5f091 100644
--- a/src/connection/tcp.rs
+++ b/src/connection/tcp.rs
@@ -6,6 +6,8 @@ use std::net::{TcpListener, TcpStream};
 use std::sync::Mutex;
 use std::time::Duration;
 
+use super::get_socket_addr;
+
 /// TCP MAVLink connection
 
 pub fn select_protocol<M: Message>(
@@ -26,15 +28,7 @@ pub fn select_protocol<M: Message>(
 }
 
 pub fn tcpout<T: ToSocketAddrs>(address: T) -> io::Result<TcpConnection> {
-    let addr = match address.to_socket_addrs()?.next() {
-        Some(addr) => addr,
-        None => {
-            return Err(io::Error::new(
-                io::ErrorKind::Other,
-                "Host address lookup failed",
-            ));
-        }
-    };
+    let addr = get_socket_addr(address)?;
 
     let socket = TcpStream::connect(addr)?;
     socket.set_read_timeout(Some(Duration::from_millis(100)))?;
@@ -50,15 +44,7 @@ pub fn tcpout<T: ToSocketAddrs>(address: T) -> io::Result<TcpConnection> {
 }
 
 pub fn tcpin<T: ToSocketAddrs>(address: T) -> io::Result<TcpConnection> {
-    let addr = match address.to_socket_addrs()?.next() {
-        Some(addr) => addr,
-        None => {
-            return Err(io::Error::new(
-                io::ErrorKind::Other,
-                "Host address lookup failed",
-            ));
-        }
-    };
+    let addr = get_socket_addr(address)?;
     let listener = TcpListener::bind(addr)?;
 
     //For now we only accept one incoming stream: this blocks until we get one
diff --git a/src/connection/udp.rs b/src/connection/udp.rs
index d8f88a314e..cb4cfeffeb 100644
--- a/src/connection/udp.rs
+++ b/src/connection/udp.rs
@@ -6,6 +6,8 @@ use std::net::ToSocketAddrs;
 use std::net::{SocketAddr, UdpSocket};
 use std::sync::Mutex;
 
+use super::get_socket_addr;
+
 /// UDP MAVLink connection
 
 pub fn select_protocol<M: Message>(
@@ -28,15 +30,7 @@ pub fn select_protocol<M: Message>(
 }
 
 pub fn udpbcast<T: ToSocketAddrs>(address: T) -> io::Result<UdpConnection> {
-    let addr = match address.to_socket_addrs()?.next() {
-        Some(addr) => addr,
-        None => {
-            return Err(io::Error::new(
-                io::ErrorKind::Other,
-                "Host address lookup failed",
-            ));
-        }
-    };
+    let addr = get_socket_addr(address)?;
     let socket = UdpSocket::bind("0.0.0.0:0").unwrap();
     socket
         .set_broadcast(true)
@@ -45,29 +39,13 @@ pub fn udpbcast<T: ToSocketAddrs>(address: T) -> io::Result<UdpConnection> {
 }
 
 pub fn udpout<T: ToSocketAddrs>(address: T) -> io::Result<UdpConnection> {
-    let addr = match address.to_socket_addrs()?.next() {
-        Some(addr) => addr,
-        None => {
-            return Err(io::Error::new(
-                io::ErrorKind::Other,
-                "Host address lookup failed",
-            ));
-        }
-    };
+    let addr = get_socket_addr(address)?;
     let socket = UdpSocket::bind("0.0.0.0:0")?;
     UdpConnection::new(socket, false, Some(addr))
 }
 
 pub fn udpin<T: ToSocketAddrs>(address: T) -> io::Result<UdpConnection> {
-    let addr = match address.to_socket_addrs()?.next() {
-        Some(addr) => addr,
-        None => {
-            return Err(io::Error::new(
-                io::ErrorKind::Other,
-                "Host address lookup failed",
-            ));
-        }
-    };
+    let addr = get_socket_addr(address)?;
     let socket = UdpSocket::bind(addr)?;
     UdpConnection::new(socket, true, None)
 }