We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c4e4c9c commit af40f35Copy full SHA for af40f35
README.md
@@ -122,3 +122,17 @@ taskiq_broker.task(
122
...,
123
)
124
```
125
+
126
+Also, you can send a multiple message by one task call just using generator message callback with `yield`
127
128
+```python
129
+async def collect_information_to_send():
130
+ """Sends 10 messages per task call."""
131
+ for i in range(10):
132
+ yield i
133
134
+taskiq_broker.task(
135
+ message=collect_information_to_send,
136
+ ...,
137
+)
138
+```
taskiq_faststream/__about__.py
@@ -1,2 +1,2 @@
1
"""FastStream - taskiq integration to schedule FastStream tasks."""
2
-__version__ = "0.1.3"
+__version__ = "0.1.4"
0 commit comments