diff --git a/examples/events.rs b/examples/events.rs
index eee35f4..aa6f03b 100644
--- a/examples/events.rs
+++ b/examples/events.rs
@@ -8,14 +8,15 @@ use futures::stream::StreamExt;
 
 #[tokio::main]
 async fn main() -> Result<(), String> {
-    let (connection, mut handle, mut messages) = new_connection().map_err(|e| format!("{}", e))?;
+    let (connection, mut handle, mut events) =
+        new_connection().map_err(|e| format!("{}", e))?;
 
     tokio::spawn(connection);
     handle.enable_events().await.map_err(|e| format!("{}", e))?;
 
     env_logger::init();
-    while let Some((msg, _)) = messages.next().await {
-        println!("{:?}", msg);
+    while let Some(event) = events.next().await {
+        println!("{event:?}");
     }
     Ok(())
 }
diff --git a/src/lib.rs b/src/lib.rs
index fd34c3a..d1b1d6a 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -21,10 +21,12 @@ use futures::channel::mpsc::UnboundedReceiver;
 pub fn new_connection() -> io::Result<(
     proto::Connection<packet::AuditMessage, sys::TokioSocket, packet::NetlinkAuditCodec>,
     Handle,
-    UnboundedReceiver<(
-        packet::NetlinkMessage<packet::AuditMessage>,
-        sys::SocketAddr,
-    )>,
+    UnboundedReceiver<
+        packet::NetlinkEvent<(
+            packet::NetlinkMessage<packet::AuditMessage>,
+            sys::SocketAddr,
+        )>,
+    >,
 )> {
     new_connection_with_socket()
 }
@@ -33,10 +35,12 @@ pub fn new_connection() -> io::Result<(
 pub fn new_connection_with_socket<S>() -> io::Result<(
     proto::Connection<packet::AuditMessage, S, packet::NetlinkAuditCodec>,
     Handle,
-    UnboundedReceiver<(
-        packet::NetlinkMessage<packet::AuditMessage>,
-        sys::SocketAddr,
-    )>,
+    UnboundedReceiver<
+        packet::NetlinkEvent<(
+            packet::NetlinkMessage<packet::AuditMessage>,
+            sys::SocketAddr,
+        )>,
+    >,
 )>
 where
     S: sys::AsyncSocket,