# Rxjava Flowables - Who controls the speed of events?

**URL:** <https://forum.canton.network/t/rxjava-flowables-who-controls-the-speed-of-events/4851>\
**Category:** App Development\
**Tags:** ledger-api\
**Created:** [July 7, 2022, 5:42am UTC](https://forum.canton.network/t/rxjava-flowables-who-controls-the-speed-of-events/4851 "2022-07-07T05:42:43Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![huw](https://yyz2.discourse-cdn.com/flex034/user_avatar/forum.canton.network/huw/32/2343_2.png) [@huw](https://forum.canton.network/u/huw)\
**Post date:** [July 7, 2022, 5:42am UTC](https://forum.canton.network/t/rxjava-flowables-who-controls-the-speed-of-events/4851/1 "2022-07-07T05:42:43Z")

</div>

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?

---

<div class="post-metadata">

**Author:** ![stefanobaghino-da](https://yyz2.discourse-cdn.com/flex034/user_avatar/forum.canton.network/stefanobaghino-da/32/7057_2.png) [@stefanobaghino-da](https://forum.canton.network/u/stefanobaghino-da)\
**Post date:** [July 7, 2022, 8:47am UTC](https://forum.canton.network/t/rxjava-flowables-who-controls-the-speed-of-events/4851/2 "2022-07-07T08:47:30Z")

</div>

RxJava as a library and the Java bindings bridge between it and gRPC conform in full to the [Reactive Streams TCK](https://www.reactive-streams.org/), 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.