diff --git a/src/channel.rs b/src/channel.rs
index 4574f75..684af0a 100644
--- a/src/channel.rs
+++ b/src/channel.rs
@@ -47,7 +47,10 @@ impl<R> Receiver for &mut R
 where
     R: Receiver,
 {
-    type Data<'a> = R::Data<'a> where Self: 'a;
+    type Data<'a>
+        = R::Data<'a>
+    where
+        Self: 'a;
 
     fn recv(&mut self) -> Result<Self::Data<'_>, Self::Error> {
         (**self).recv()
@@ -86,7 +89,10 @@ pub mod asynch {
     where
         R: Receiver,
     {
-        type Data<'a> = R::Data<'a> where Self: 'a;
+        type Data<'a>
+            = R::Data<'a>
+        where
+            Self: 'a;
 
         async fn recv(&mut self) -> Result<Self::Data<'_>, Self::Error> {
             (**self).recv().await
diff --git a/src/mqtt/client.rs b/src/mqtt/client.rs
index 41906af..675231f 100644
--- a/src/mqtt/client.rs
+++ b/src/mqtt/client.rs
@@ -211,7 +211,10 @@ impl<C> Connection for &mut C
 where
     C: Connection,
 {
-    type Event<'a> = C::Event<'a> where Self: 'a;
+    type Event<'a>
+        = C::Event<'a>
+    where
+        Self: 'a;
 
     fn next(&mut self) -> Result<Self::Event<'_>, Self::Error> {
         (*self).next()
@@ -277,7 +280,10 @@ pub mod asynch {
     where
         C: Connection,
     {
-        type Event<'a> = C::Event<'a> where Self: 'a;
+        type Event<'a>
+            = C::Event<'a>
+        where
+            Self: 'a;
 
         async fn next(&mut self) -> Result<Self::Event<'_>, Self::Error> {
             (*self).next().await
diff --git a/src/ota.rs b/src/ota.rs
index 9d9861e..bf925a8 100644
--- a/src/ota.rs
+++ b/src/ota.rs
@@ -105,7 +105,10 @@ impl<O> Ota for &mut O
 where
     O: Ota,
 {
-    type Update<'a> = O::Update<'a> where Self: 'a;
+    type Update<'a>
+        = O::Update<'a>
+    where
+        Self: 'a;
 
     fn get_boot_slot(&self) -> Result<Slot, Self::Error> {
         (**self).get_boot_slot()
@@ -207,7 +210,10 @@ pub mod asynch {
     where
         O: Ota,
     {
-        type Update<'a> = O::Update<'a> where Self: 'a;
+        type Update<'a>
+            = O::Update<'a>
+        where
+            Self: 'a;
 
         async fn get_boot_slot(&self) -> Result<Slot, Self::Error> {
             (**self).get_boot_slot().await
diff --git a/src/ws.rs b/src/ws.rs
index 2469821..4df688f 100644
--- a/src/ws.rs
+++ b/src/ws.rs
@@ -92,7 +92,10 @@ pub mod server {
     where
         A: Acceptor,
     {
-        type Connection<'a> = A::Connection<'a> where Self: 'a;
+        type Connection<'a>
+            = A::Connection<'a>
+        where
+            Self: 'a;
 
         fn accept(&self) -> Result<Self::Connection<'_>, Self::Error> {
             (*self).accept()
@@ -103,7 +106,10 @@ pub mod server {
     where
         A: Acceptor,
     {
-        type Connection<'a> = A::Connection<'a> where Self: 'a;
+        type Connection<'a>
+            = A::Connection<'a>
+        where
+            Self: 'a;
 
         fn accept(&self) -> Result<Self::Connection<'_>, Self::Error> {
             (**self).accept()
@@ -172,8 +178,14 @@ pub mod asynch {
         where
             A: Acceptor,
         {
-            type Sender<'a> = A::Sender<'a> where Self: 'a;
-            type Receiver<'a> = A::Receiver<'a> where Self: 'a;
+            type Sender<'a>
+                = A::Sender<'a>
+            where
+                Self: 'a;
+            type Receiver<'a>
+                = A::Receiver<'a>
+            where
+                Self: 'a;
 
             async fn accept(&self) -> Result<(Self::Sender<'_>, Self::Receiver<'_>), Self::Error> {
                 (*self).accept().await
@@ -184,8 +196,14 @@ pub mod asynch {
         where
             A: Acceptor,
         {
-            type Sender<'a> = A::Sender<'a> where Self: 'a;
-            type Receiver<'a> = A::Receiver<'a> where Self: 'a;
+            type Sender<'a>
+                = A::Sender<'a>
+            where
+                Self: 'a;
+            type Receiver<'a>
+                = A::Receiver<'a>
+            where
+                Self: 'a;
 
             async fn accept(&self) -> Result<(Self::Sender<'_>, Self::Receiver<'_>), Self::Error> {
                 (**self).accept().await