diff --git a/permchain/topic.py b/permchain/topic.py
index b1369ff76..9456caf06 100644
--- a/permchain/topic.py
+++ b/permchain/topic.py
@@ -158,6 +158,7 @@ class RunnablePublisherEach(RunnablePublisher[Sequence[T]]):
     ) -> Sequence[T]:
         for item in input:
             super().invoke(item, config)
+        return input
 
 
 class RunnableCurrentValue(Serializable, Runnable[Any, T]):