diff --git a/tokio-xmpp/Cargo.toml b/tokio-xmpp/Cargo.toml
index d6a9f39b88b7271367fc24f708df5e2328f70b31..c5aa823efe9fee4100827a5e7b7cd02c21aebcc9 100644
--- a/tokio-xmpp/Cargo.toml
+++ b/tokio-xmpp/Cargo.toml
@@ -19,7 +19,7 @@ log = "0.4"
 native-tls = "0.2"
 sasl = "0.4"
 tokio = { version = "0.2", features = ["net", "stream", "rt-util", "rt-threaded", "macros"] }
-tokio-util = { version = "0.2", features = ["codec"] }
+tokio-util = { version = "0.3", features = ["codec"] }
 tokio-tls = "0.3"
 trust-dns-resolver = "0.19"
 trust-dns-proto = "0.19"
diff --git a/tokio-xmpp/src/xmpp_codec.rs b/tokio-xmpp/src/xmpp_codec.rs
index bbc0ee101f13aec4c8ec4967879f47becd7bfdcf..6c6b92cc2da87d7e83de4915957f642ce74ff38d 100644
--- a/tokio-xmpp/src/xmpp_codec.rs
+++ b/tokio-xmpp/src/xmpp_codec.rs
@@ -272,11 +272,10 @@ impl Decoder for XMPPCodec {
     }
 }
 
-impl Encoder for XMPPCodec {
-    type Item = Packet;
+impl Encoder<Packet> for XMPPCodec {
     type Error = io::Error;
 
-    fn encode(&mut self, item: Self::Item, dst: &mut BytesMut) -> Result<(), Self::Error> {
+    fn encode(&mut self, item: Packet, dst: &mut BytesMut) -> Result<(), Self::Error> {
         let remaining = dst.capacity() - dst.len();
         let max_stanza_size: usize = 2usize.pow(16);
         if remaining < max_stanza_size {