chore: short form

viz-rs · Dec 22, 2023 · 468a571 · 468a571
1 parent 7285359
commit 468a571
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 16 deletions.
diff --git a/viz-core/src/body.rs b/viz-core/src/body.rs
@@ -52,11 +52,10 @@ impl Body {
         B::Data: Into<Bytes>,
         B::Error: Into<BoxError>,
     {
-        Self::Boxed(SyncWrapper::new(
-            body.map_frame(|frame| frame.map_data(Into::into))
-                .map_err(Error::boxed)
-                .boxed_unsync(),
-        ))
+        body.map_frame(|frame| frame.map_data(Into::into))
+            .map_err(Error::boxed)
+            .boxed_unsync()
+            .into()
     }
 
     /// A body created from a [`Stream`].
@@ -66,15 +65,14 @@ impl Body {
         S::Ok: Into<Bytes>,
         S::Error: Into<BoxError>,
     {
-        Self::Boxed(SyncWrapper::new(
-            StreamBody::new(
-                stream
-                    .map_ok(Into::into)
-                    .map_ok(Frame::data)
-                    .map_err(Error::boxed),
-            )
-            .boxed_unsync(),
-        ))
+        StreamBody::new(
+            stream
+                .map_ok(Into::into)
+                .map_ok(Frame::data)
+                .map_err(Error::boxed),
+        )
+        .boxed_unsync()
+        .into()
     }
 
     /// A stream created from a [`http_body::Body`].

diff --git a/viz-core/src/handler/service.rs b/viz-core/src/handler/service.rs
@@ -38,8 +38,8 @@ where
                     body.map_frame(|f| f.map_data(Into::into))
                         .map_err(Into::into)
                         .boxed_unsync()
+                        .into()
                 })
-                .map(Into::into)
             })
             .map_err(Into::into)
     }

diff --git a/viz-tower/src/lib.rs b/viz-tower/src/lib.rs
@@ -37,8 +37,8 @@ where
                     body.map_frame(|f| f.map_data(Into::into))
                         .map_err(Error::boxed)
                         .boxed_unsync()
+                        .into()
                 })
-                .map(Into::into)
             })
             .map_err(Error::boxed)
     }