Website about Reactive Programing written on non-reactive website with static pages.


Observable - filtering functions

After we can create and transform Observable, is good to know, how to filter emitted items and get only items, which we want or we expect.


RxSmalltalk - implementing reactive library part 2

After implementing base Observable, we can implement other basic Observable types like Empty, Throw, Never and so on.


Reactive WebSocket

Few days back, I needed to use WebSockets on the client to get almost real-time communication with the backend. And I was thinking if is possible to simply connect RxJava to Java web sockets.


How to test TimerTask

Image situation, that you have some task, which must be run after specified time. In our case we have invalidated login token after some time, after successful login. So, lets go to implement it.


Observable - transformation functions

Transformation functions change emitted items of Observable into another type, which is emitted.