How do I implement sending continuous updates (progressive results) in a registered procedure?

[offroff]

We are doing this in another project, written in go. Now we want to do the same in java but I'm not sure if we're able to implement it at all. If it's possible, can you provide an example?

What we want to do is listening to events on some equipment, customer or similar, there's billions of combinations we might be interested in, so I don't think it makes sense to solve this by publishing to topics. I guess it would be possible to dynamically generate new topics though.

Still, if it's possible to do the same with registered procedures, can you provide some hints on how to do it?