diff --git a/crates/transport/src/frame/conn/client.rs b/crates/transport/src/frame/conn/client.rs
index 9583b261..07ae1694 100644
--- a/crates/transport/src/frame/conn/client.rs
+++ b/crates/transport/src/frame/conn/client.rs
@@ -49,6 +49,7 @@ impl<H> InvokeBuilder<H> {
         tx.write_all(&buf)
             .await
             .context("failed to initialize connection")?;
+        tx.flush().await.context("failed to flush invocation")?;
 
         let Conn { tx, rx } = Conn::new::<H, _, _, _>(rx, tx, paths.as_ref());
         Ok((tx, rx))
diff --git a/crates/transport/src/frame/conn/mod.rs b/crates/transport/src/frame/conn/mod.rs
index 2dcb357c..9c7514ed 100644
--- a/crates/transport/src/frame/conn/mod.rs
+++ b/crates/transport/src/frame/conn/mod.rs
@@ -500,6 +500,7 @@ async fn egress(
         let mut frame = path.chain(&mut buf).chain(data);
         trace!(?frame, "writing egress frame");
         tx.write_all_buf(&mut frame).await?;
+        tx.flush().await?;
     }
     trace!("shutting down outgoing stream");
     tx.shutdown().await