diff --git a/packages/backend-rs/src/service/antenna/process_new_note.rs b/packages/backend-rs/src/service/antenna/process_new_note.rs
index 853fbccbe1..b9eed0eff8 100644
--- a/packages/backend-rs/src/service/antenna/process_new_note.rs
+++ b/packages/backend-rs/src/service/antenna/process_new_note.rs
@@ -81,5 +81,7 @@ async fn add_note_to_antenna(antenna_id: &str, note: &Note) -> Result<(), Error>
         .await?;
 
     // for streaming API
-    Ok(stream::antenna::publish(antenna_id.to_string(), note).await?)
+    stream::antenna::publish(antenna_id.to_string(), note).await?;
+
+    Ok(())
 }