You can apply backpressure implicitly, though, eve...
# rxe
elizarov
05/03/2018, 2:14 PMYou can apply backpressure implicitly, though, even to Rx2 observable. The longer you take to process the observed items, the more you block the producer. So, if producer is just a loop, then it will be able to emit only as many items per second as observer is able to process.
u
ursus
05/03/2018, 3:58 PMthis is what I meant, i am wrapping android api, which spams callbacks, which are emitted by android on mainthread, so ill just block main thread if downstream cant keep up right?
e
elizarov
05/03/2018, 4:20 PMYes
👍 1
2 Views