diff --git a/quinn/src/send_stream.rs b/quinn/src/send_stream.rs
index fcea07cf..b5a4240c 100644
--- a/quinn/src/send_stream.rs
+++ b/quinn/src/send_stream.rs
@@ -1,4 +1,5 @@
 use std::{
+    convert::identity,
     fmt,
     future::{Future, poll_fn},
     io,
@@ -101,6 +102,20 @@ impl SendStream {
         Ok(())
     }
 
+    pub async fn write_atomic(&mut self, buf: &[u8]) -> Result<(), WriteAtomicError> {
+        self.write_source(|limit, chunks| {
+            if limit >= buf.len() {
+                chunks.push(buf.to_vec().into());
+                Ok(())
+            } else {
+                Err(WriteAtomicError::TooLarge)
+            }
+        })
+        .await
+        .map_err(|e| WriteAtomicError::WriteError(e.error))
+        .and_then(identity)
+    }
+
     /// Attempts to write bytes into this stream from a byte-providing callback
     ///
     /// This is a low-level writing API that can be used to perform writes in a way that is atomic
@@ -465,3 +480,14 @@ impl<F> From<WriteSourceError<F>> for io::Error {
         e.error.into()
     }
 }
+
+/// Errors that arise from writing to a stream atomically
+#[derive(Debug, Error, Clone, PartialEq, Eq)]
+pub enum WriteAtomicError {
+    /// The write was too large to send atomically at this time
+    #[error("too large for atomic write")]
+    TooLarge,
+    /// Some other write error occurred
+    #[error("stream write error")]
+    WriteError(WriteError),
+}