RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences

learn more… | top users | synonyms

2
votes
0answers
25 views

Refactoring App launch sequence using reactive programming

In the SplashActivity of my Android Application, the following sequence of events occur: Check Google Play Services is installed If Google Play Services available, start ...
1
vote
1answer
85 views

Testing a ViewModel in Android - MVVM with DataBinding

I am using MVVM pattern with databinding. I have written tests. But I want them reviewed. The test is related to JUnit test on the ViewModel. FeedViewModelTest....
0
votes
1answer
55 views

Finding the mean using RxJava

I'm learning RxJava and this is what I attempted to find the mean of 'n' transactions. ...
1
vote
0answers
31 views

Testing a method which coordinates multiple objects

I have this class with one method, which uses three different objects to perform a task. ...
0
votes
1answer
72 views

Getting data with RxJava and retrofit

I am using RxJava with retrofit to get data from an API then filtering the data with a for loop in the onNext Method. Is there ...
3
votes
2answers
121 views

Cache of shared observables (Rx)

So the idea is to maintain a cache of shared Observables - accessible by a key - which if not present will produce one using the given factory. The underlying shared Observable is accessed via an ...
3
votes
1answer
30 views

RXJava operate on exiting List instead of creating new

I'm dipping my toes in to RXJava for the first time. The function below works just fine but I can't help thinking it can be improved. For instance I'm sure that I'm unnecessarily creating a new ...
5
votes
1answer
263 views

Finding local C# servers on a Java client using UDP and reactive extensions

This program uses UDP broadcast to find app servers on the local network. When a server receives a client broadcast, it sends a port (integer) to the client which will later be used to create a TCP ...
1
vote
1answer
145 views

Android UI code for a test job

I wrote my first Android UI application for a test job, but it was declined as employer said that he did't like "the code quality". He didn't specify what he meant. But I'm very interesting to know ...
3
votes
1answer
241 views

Manager for OAuth2 tokens using RxJava

I have a class in my application which manages storage of OAuth2 tokens. There are unauthenticated tokens (in my code, called "application access tokens") which can be used for API calls that do not ...
3
votes
1answer
78 views

Coordinating Threads with Reactive Streams

I just started learning reactive streams with RxJava. After reading a couple of books and a lot of articles our there I am still having trouble understanding how to coordinate multiple threads. I ...
2
votes
0answers
157 views

Using combinations of OR and AND filters with RxJava

I'm trying to work out a way to create a combination of OR and AND filters in RxJava. Here's what I've done so far: ...
3
votes
1answer
272 views

Using a Subject to trigger a music list to reload

In my Android app I have a Service that is periodically polling a server for a music playlist XML. For certain occasions I also want to trigger a reload manually. I am using Retrofit for the server ...