Skip to main content

Questions tagged [rx-java]

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

Filter by
Sorted by
Tagged with
2 votes
0 answers
243 views

Kotlin 1.3.+ RxJava 3.0.+ Kotest 4.1.+ ...
Andrey's user avatar
  • 121
2 votes
1 answer
68 views

I implemented a class for relationships with the user (deletion, name change, check for existence), I created this class to remove extra logic from the activity class. Could you talk about how my code ...
Destroyer's user avatar
  • 459
3 votes
0 answers
1k views

I have an interactor/usecase class in my application. My application follows MVVM architecture with interactor/usecases responsible for logic (e.g. get data from api-service, store in local-database ...
CJR's user avatar
  • 151
3 votes
0 answers
84 views

I am new to RxJava and have the following code which I use to search YouTube videos via the API and ultimately display them in a list. ...
Adam's user avatar
  • 331
4 votes
2 answers
167 views

Here's my method used for parsing a ByteArray into multiple frames of CAN interface. It works now correctly but it's somewhat ugly in my opinion. It's written in ...
Ernest Zamelczyk's user avatar
0 votes
1 answer
230 views

I have tried to create the async task using the RxJAVA2. The code is working fine. WHat enhancement can I do in this code? ...
Ankur_009's user avatar
  • 131
2 votes
1 answer
489 views

I started using Retrofit and RxJava recently and I love it. I am working on an Android project and I am following MVP Repository pattern as specified in Android Architecture Components. I'm still ...
rupinderjeet's user avatar
3 votes
1 answer
160 views

I have a PR for a bugfix in which the fix is just 4 characters. In this situation we are invited to make some refactoring on the class that we are touching if possible. Venkat Subramaniam's advice is ...
Human's user avatar
  • 133
0 votes
1 answer
223 views

I have a complicated Dagger 2 use case on Android, where I have a lot of dependencies, but some of them are really slow to construct. Like 2-3 seconds slow. My solution was to create an RX ...
milosmns's user avatar
  • 103
3 votes
0 answers
964 views

I'm trying to understand how to bridge receiver-based events to the Reactive world. I asked a question on SO and was pointed to a different approach. The author of that answer (David Karnok) is ...
Kevin Krumwiede's user avatar
3 votes
0 answers
2k views

I'm working on an Android (Java) project which utilizes different analytic metrics (sum of x group by date, sum of x group by id, etc) and I am projecting the data sets into different charts using ...
emen's user avatar
  • 151
2 votes
0 answers
65 views

I want to implement a service that fetches eyetracking events and publishes them to all subscribers of the stream. The whole thing is supposed to run asynchronously, so it doesn't block the UI thread. ...
Luca Fülbier's user avatar
4 votes
1 answer
205 views

In the past, I have used AsyncTasks to perform network requests for my Android app. I recently switched to RxJava to be able to cancel the requests when the user exits an activity. I have created a ...
Jtvd78's user avatar
  • 141
5 votes
0 answers
165 views

I have a service with these methods: Observable<User> getUsers(); Observable<Role> getUserRoles(String userId); For each user, I want to get her ...
Héctor Valls's user avatar
2 votes
0 answers
89 views

In the SplashActivity of my Android Application, the following sequence of events occur: Check if Google Play Services is installed If Google Play Services are ...
menawi's user avatar
  • 21
4 votes
1 answer
5k views

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....
Raghunandan's user avatar
0 votes
1 answer
145 views

I'm learning RxJava and this is what I attempted to find the mean of 'n' transactions. ...
Ragunath Jawahar's user avatar
0 votes
1 answer
789 views

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 ...
lostForAWHile's user avatar
3 votes
2 answers
989 views

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 ...
Ross Anderson's user avatar
3 votes
1 answer
105 views

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 ...
Ivan Wooll's user avatar
5 votes
1 answer
730 views

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 ...
flakes's user avatar
  • 1,945
1 vote
1 answer
270 views

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 ...
Paltr's user avatar
  • 13
3 votes
1 answer
1k views

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 ...
Damien Diehl's user avatar
3 votes
1 answer
551 views

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 ...
Edwin Dalorzo's user avatar
3 votes
0 answers
609 views

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: ...
Crystark's user avatar
  • 131
4 votes
1 answer
689 views

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 ...
david.mihola's user avatar