diff --git a/Cargo.toml b/Cargo.toml
index e1fb776..5eb91bd 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -25,6 +25,7 @@ features = [
   "wincon",
   "winerror",
   "winnt",
+  "winsock2",
 ]
 
 [package.metadata.docs.rs]
diff --git a/src/lib.rs b/src/lib.rs
index 0bb259d..f1a8535 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -29,4 +29,6 @@ pub mod console;
 #[cfg(windows)]
 pub mod file;
 #[cfg(windows)]
+pub mod socket;
+#[cfg(windows)]
 mod win;
diff --git a/src/socket.rs b/src/socket.rs
new file mode 100644
index 0000000..9fb34ae
--- /dev/null
+++ b/src/socket.rs
@@ -0,0 +1,71 @@
+use std::convert::TryInto;
+use std::io;
+
+use winapi::shared::minwindef::INT;
+use winapi::um::winsock2::{WSAPoll, WSAPOLLFD};
+
+/// `wsa_poll` waits for one of a set of file descriptors to become ready to
+/// perform I/O.
+///
+/// This corresponds to calling [`WSAPoll`].
+///
+/// [`WSAPoll`]: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-wsapoll
+pub fn wsa_poll(
+    fd_array: &mut [WSAPOLLFD],
+    timeout: INT,
+) -> io::Result<usize> {
+    unsafe {
+        let length = fd_array.len().try_into().unwrap();
+        let rc = WSAPoll(fd_array.as_mut_ptr(), length, timeout);
+        if rc < 0 {
+            return Err(io::Error::last_os_error());
+        };
+        Ok(rc.try_into().unwrap())
+    }
+}
+
+#[cfg(test)]
+mod test {
+    use std::io::{Result, Write};
+    use std::net::{TcpListener, TcpStream};
+    use std::os::windows::io::{AsRawSocket, RawSocket};
+
+    use winapi::um::winnt::SHORT;
+    use winapi::um::winsock2::{POLLIN, POLLOUT, POLLRDNORM, WSAPOLLFD};
+
+    use super::wsa_poll;
+
+    /// Get a pair of connected TcpStreams
+    fn get_connection_pair() -> Result<(TcpStream, TcpStream)> {
+        let listener = TcpListener::bind("127.0.0.1:0")?;
+        let stream1 = TcpStream::connect(listener.local_addr()?)?;
+        let stream2 = listener.accept()?.0;
+
+        Ok((stream1, stream2))
+    }
+
+    fn poll(socket: RawSocket, events: SHORT, revents: SHORT) -> Result<()> {
+        let mut sockets = [WSAPOLLFD { fd: socket as _, events, revents: 0 }];
+        let count = wsa_poll(&mut sockets, -1)?;
+        assert_eq!(count, 1);
+        assert_eq!(sockets[0].revents, revents);
+
+        Ok(())
+    }
+
+    #[test]
+    fn test_poll() -> Result<()> {
+        let (mut stream1, stream2) = get_connection_pair()?;
+
+        // Check that stream1 is writable
+        poll(stream1.as_raw_socket(), POLLOUT, POLLOUT)?;
+
+        // Write something to the stream
+        stream1.write_all(b"1")?;
+
+        // stream2 should now be readable and writable
+        poll(stream2.as_raw_socket(), POLLIN | POLLOUT, POLLOUT | POLLRDNORM)?;
+
+        Ok(())
+    }
+}