The preferred way to do this with RSocket and Proteus is with the request-stream interaction model. You will subscribe to a Flux and specify the “request-n” or in other words the number of items you would like to stream. You will request a certain number of items and when you process all of those you will request another batch ie. If you want to just get items forever you can request maximum value of long or you can request something less than that and just request more when you run out.
That makes total sense, thanks!