diff --git a/docs/integrations/event-streams/faststream.md b/docs/integrations/event-streams/faststream.md index 0d76e0cdf..339b9a16f 100644 --- a/docs/integrations/event-streams/faststream.md +++ b/docs/integrations/event-streams/faststream.md @@ -26,8 +26,9 @@ app = FastStream(broker) @broker.subscriber("test-channel") +@broker.publisher("another-channel") async def handle(): - await broker.publish("Hi!", channel="another-channel") + return "Hi!" @broker.subscriber("another-channel")