diff --git a/src/dialog/dialog.rs b/src/dialog/dialog.rs
index 0aa8c9a..a09c220 100644
--- a/src/dialog/dialog.rs
+++ b/src/dialog/dialog.rs
@@ -15,6 +15,7 @@ use crate::{
     transport::SipAddr,
     Result,
 };
+use futures::FutureExt;
 use rsip::{
     headers::Route,
     message::HasHeaders,
@@ -792,7 +793,7 @@ impl DialogInner {
     }
 
     pub(super) async fn do_request(&self, request: Request) -> Result<Option<Response>> {
-        self.send_dialog_request(request).await
+        self.send_dialog_request(request).boxed().await
     }
 
     pub(super) fn transition(&self, state: DialogState) -> Result<()> {
diff --git a/src/dialog/invitation.rs b/src/dialog/invitation.rs
index 2806890..d083965 100644
--- a/src/dialog/invitation.rs
+++ b/src/dialog/invitation.rs
@@ -14,6 +14,7 @@ use crate::{
     transport::SipAddr,
     Result,
 };
+use futures::FutureExt;
 use rsip::{
     prelude::{HeadersExt, ToTypedHeader},
     Request, Response,
@@ -430,7 +431,7 @@ impl DialogLayer {
             id: &id,
         };
 
-        let r = dialog.process_invite(tx).await;
+        let r = dialog.process_invite(tx).boxed().await;
         self.inner
             .dialogs
             .write()
diff --git a/src/dialog/tests/test_client_dialog.rs b/src/dialog/tests/test_client_dialog.rs
index df38122..f0be7b1 100644
--- a/src/dialog/tests/test_client_dialog.rs
+++ b/src/dialog/tests/test_client_dialog.rs
@@ -362,8 +362,7 @@ async fn test_make_request_preserves_remote_target_and_route_order() -> crate::R
         .expect("route-enabled request should resolve to a destination");
     let expected_destination = Uri::try_from("sip:proxy2.example.com:5070;transport=tcp;lr")?;
     assert_eq!(
-        &*destination,
-        &expected_destination,
+        &*destination, &expected_destination,
         "First Route entry must determine the transport destination"
     );
 
diff --git a/src/transport/stream.rs b/src/transport/stream.rs
index 62ff163..5929cb4 100644
--- a/src/transport/stream.rs
+++ b/src/transport/stream.rs
@@ -195,8 +195,7 @@ where
 
         let mut codec = SipCodec::new();
         let mut buffer = BytesMut::with_capacity(MAX_SIP_MESSAGE_SIZE);
-        let mut read_buf = [0u8; MAX_SIP_MESSAGE_SIZE];
-
+        let mut read_buf = vec![0u8; MAX_SIP_MESSAGE_SIZE];
         loop {
             use tokio::io::AsyncReadExt;
             match read_half.read(&mut read_buf).await {