Fix HTTPChannel and HTTPChannelBackend

Author: RussellLuo

coagent/core/runtime.py

@@ -131,8 +131,8 @@ async def _publish_stream(
         await self._publish(
             addr,
             msg,
-            request=True,
             stream=True,
+            request=True,
             reply=inbox,
             probe=probe,
         )

coagent/runtimes/http_runtime.py

@@ -109,6 +109,7 @@ async def _publish_stream(
             addr=addr.encode(mode="json"),
             msg=msg.encode(mode="json"),
             stream=True,
+            request=True,
             probe=probe,
         )
         headers = {"Authorization": self._auth} if self._auth else None
@@ -274,7 +275,7 @@ async def publish(
         reply: str = "",
         timeout: float = 5.0,
         probe: bool = True,
-    ) -> RawMessage | None:
+    ) -> AsyncIterator[RawMessage] | RawMessage | None:
         return await self._channel.publish(
             addr,
             msg,