Perhaps you can simplify the problem and avoid runtime evaluation of ASTs.
Thiago Araújo Silva

This is an interesting idea. It’s like the reverse of mine :)

In my use case I have several messages per second and perhaps hundreds of subscribers. Each subscriber needs to receive only a small fraction of all messages, so I think the performance penalty of sending all messages to all subscribers is too big in my case.

I think it might also be hard to customize how to receive with this approach. E.g. how to handle multiple subscription, receive other (unrelated) messages or add a timeout.

Like what you read? Give Lasse Ebert a round of applause.

From a quick cheer to a standing ovation, clap to show how much you enjoyed this story.