Unnecessary BoxBody

crates/roc_http/src/lib.rs

@@ -1,20 +1,16 @@
 //! This crate provides common functionality for Roc to interface with `std::net::tcp`
 use roc_std::{RocBox, RocList, RocRefcounted, RocResult, RocStr};
 use roc_std_heap::ThreadSafeRefcountedResourceHeap;
-use std::convert::Infallible;
 use std::env;
 use std::io::{BufRead, BufReader, ErrorKind, Read, Write};
 use std::net::TcpStream;
 use std::sync::OnceLock;
 use bytes::Bytes;
-use http_body_util::BodyExt;
 
 pub const REQUEST_TIMEOUT_BODY: &[u8] = "RequestTimeout".as_bytes();
 pub const REQUEST_NETWORK_ERR: &[u8] = "Network Error".as_bytes();
 pub const REQUEST_BAD_BODY: &[u8] = "Bad Body".as_bytes();
 
-type BoxBody = http_body_util::combinators::BoxBody<Bytes, Infallible>;
-
 pub fn heap() -> &'static ThreadSafeRefcountedResourceHeap<BufReader<TcpStream>> {
     // TODO: Should this be a BufReader and BufWriter of the tcp stream?
     // like this: https://stackoverflow.com/questions/58467659/how-to-store-tcpstream-with-bufreader-and-bufwriter-in-a-data-structure/58491889#58491889
@@ -196,7 +192,7 @@ impl From<hyper::http::Error> for ResponseToAndFromHost {
     }
 }
 
-impl From<ResponseToAndFromHost> for hyper::Response<BoxBody> {
+impl From<ResponseToAndFromHost> for hyper::Response<http_body_util::Full<Bytes>> {
     fn from(roc_response: ResponseToAndFromHost) -> Self {
         let mut builder = hyper::Response::builder();
 
@@ -211,7 +207,7 @@ impl From<ResponseToAndFromHost> for hyper::Response<BoxBody> {
         }
 
         builder
-            .body(http_body_util::Full::new(Vec::from(roc_response.body.as_slice()).into()).boxed()) // TODO try not to use Vec here
+            .body(http_body_util::Full::new(Vec::from(roc_response.body.as_slice()).into())) // TODO try not to use Vec here
             .unwrap() // TODO don't unwrap this
     }
 }