Skip to content
CCPEDIAby Unity Nodes
Discussions/App Development/Rxjava Flowables - Who controls the speed of events?Forum ↗

Rxjava Flowables - Who controls the speed of events?

App Development2 posts224 viewsLast activity Jul 2022
HU
huwOP
Jul 2022

Hi there, I’m using the gRPC rxjava bindings. For any of the ledger API calls which return a Flowable can the java application limit the speed at which events are received on the Flowable? Or does the ledger API just send them at whatever speed it wants?

ST
stefanobaghino-da
Jul 2022

RxJava as a library and the Java bindings bridge between it and gRPC conform in full to the Reactive Streams TCK, which means that the speed of consumption is regulated by the built-in back-pressure mechanism (more traditionally referred to as flow control). In practice this means that a consumer will dynamically ask for as many items as the pipeline can process at any given point in time. Certain RxJava operators exist exclusively to regulate flow control by imposing limits in terms of time or space.

← Back to Discussions