1 files changed, 32 insertions, 0 deletions
diff --git a/third_party/rust/warp/examples/multipart.rs b/third_party/rust/warp/examples/multipart.rs
new file mode 100644
index 0000000000..e28dd01de1
--- /dev/null
+++ b/third_party/rust/warp/examples/multipart.rs
@@ -0,0 +1,32 @@
+use bytes::BufMut;
+use futures_util::TryStreamExt;
+use warp::multipart::FormData;
+use warp::Filter;
+
+#[tokio::main]
+async fn main() {
+    // Running curl -F file=@.gitignore 'localhost:3030/' should print [("file", ".gitignore", "\n/target\n**/*.rs.bk\nCargo.lock\n.idea/\nwarp.iml\n")]
+    let route = warp::multipart::form().and_then(|form: FormData| async move {
+        let field_names: Vec<_> = form
+            .and_then(|mut field| async move {
+                let mut bytes: Vec<u8> = Vec::new();
+
+                // field.data() only returns a piece of the content, you should call over it until it replies None
+                while let Some(content) = field.data().await {
+                    let content = content.unwrap();
+                    bytes.put(content);
+                }
+                Ok((
+                    field.name().to_string(),
+                    field.filename().unwrap().to_string(),
+                    String::from_utf8_lossy(&*bytes).to_string(),
+                ))
+            })
+            .try_collect()
+            .await
+            .unwrap();
+
+        Ok::<_, warp::Rejection>(format!("{:?}", field_names))
+    });
+    warp::serve(route).run(([127, 0, 0, 1], 3030)).await;
+}