Fix StreamWriter::write_all wrt WebAssembly/component-model#490

alexcrichton · alexcrichton · commit bb9515457ea7 · 2025-04-03T11:20:22.000-07:00
Handle the fact that cancellation/0-length writes look the same.
diff --git a/crates/guest-rust/rt/src/async_support/stream_support.rs b/crates/guest-rust/rt/src/async_support/stream_support.rs
@@ -160,6 +160,11 @@ impl<T> StreamWriter<T> {
                 break;
             }
             (status, buf) = self.write_buf(buf).await;
+
+            // FIXME(WebAssembly/component-model#490)
+            if status == StreamResult::Cancelled {
+                status = StreamResult::Complete(0);
+            }
         }
 
         // Return back any values that weren't written by shifting them to the

Original file line number	Diff line number	Diff line change
`@@ -160,6 +160,11 @@ impl<T> StreamWriter<T> {`
`160`	`160`	`break;`
`161`	`161`	`}`
`162`	`162`	`(status, buf) = self.write_buf(buf).await;`
	`163`	`+`
	`164`	`+ // FIXME(WebAssembly/component-model#490)`
	`165`	`+ if status == StreamResult::Cancelled {`
	`166`	`+ status = StreamResult::Complete(0);`
	`167`	`+ }`
`163`	`168`	`}`
`164`	`169`
`165`	`170`	`// Return back any values that weren't written by shifting them to the`