Merge pull request #67 from kinode-dao/da/docstring

await_next_request_body > await_next_message_body

src/lib.rs

@@ -217,9 +217,10 @@ pub fn get_capability(our: &Address, params: &str) -> Option<Capability> {
         .cloned()
 }
 
-pub fn await_next_request_body() -> anyhow::Result<Vec<u8>> {
-    let Ok(Message::Request { body, .. }) = await_message() else {
-        return Err(anyhow::anyhow!("failed to get request body, bailing out"));
-    };
-    Ok(body)
+/// get the next message body from the message queue, or propagate the error
+pub fn await_next_message_body() -> Result<Vec<u8>, SendError> {
+    match await_message() {
+        Ok(msg) => Ok(msg.body().to_vec()),
+        Err(e) => Err(e.into()),
+    }
 }