Flowable?

[scottslewis]

I use the RxJava implementation of Flowable, which is often used (in RxJava) for the API entry point...e.g. https://github.com/ReactiveX/RxJava

I'm getting familiar with RxPy, and there does not appear to be any Flowable (or similar) api for RxPy. Is this correct? Is there any desire to have classes similar to Flowable in RxPy?

There is also a protobuf plugin to generate java code...that uses Flowable and Single as an API for streaming services...e.g. with backpressure for flow control, etc.

I would like to create a generator to gen python code for protobuf streaming services for python<->Java streaming.

I'm able and willing to help impl if this requires additions to RxPy, but would like to understand better where RxPy team is on this.

[MichaelSchneeberger]

I created rxbp that implements Flowable for RxPy with backpressure support. I used it for hardware-in-the-loop testing, where it efficiently handled measurement data arriving at varying rates. While powerful, the current implementation is complex and can be challenging to debug.