FAN-IN pattern that waits until every channel has a message

[Steven-Livingstone]

Hi!

If subscribing to multiple streams as described here:

@broker.subscriber("first_sub")
@broker.subscriber("second_sub")
async def handler(msg):
    ...

Can the handler function wait until both streams have a message? (kinda like asyncio.gather)

I'm imaging something like:

@broker.subscriber("first_sub")
@broker.subscriber("second_sub")
async def handler(msg1, msg2):
    ...

[Lancetnik]

No, FastStream has no builtin Fan-In subscribers, but you can implement smth close using dynamic subscribers feature

[Steven-Livingstone]

Thanks @Lancetnik! Also referencing #2533 incase a solution is found.