RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
So 100 trees are based off one tree model etc. One instance of memory
Pls I need help on self service android app
Whats the simplest way to add backpressure into a .connect() call ? Right now, I simply do a 'Thread.sleep()' if the last connect action took more then X MS. I'd like to do this based on rate, i.e. "if the rate of actions drops below X/sec, sleep". Because some actions are CPU hungry, if an action takes too long to run, it likely means it was using a large amount of CPU for a large amount of time.
It's called multithreading
Hi, I'm new to RxJava request help from the community on a scenario. I have SpringMVC setup, the RestController receives an object like "Person" with properties like FirstName, LastName..etc. The RestController needs to send back some information based on the object(Person) it receives and also in parallel make entry to the DB that this particular query about object(Person) was received. Now return from the RestController does not have to wait for DB entry to be complete, these are 2 parallel operations. Is RxJava suitable for such a scenario? If yes, how could it be used?
try to do this
this will execute the two operations in two threads
so they will be executed in parallel and with no waiting
and if your method returns a value then you can do this
Person person = new Person();
Observable<Person> personObservable = Observable.just(person).subscribeOn(Schedulers.io());
personObservable.subscribe(p -> {
// add the object to the database
});
// gets the data and return it
Hi, I am doing my GSoC project https://github.com/therajanmaurya/android-client-2.0 in which I am using RxJava 2 and handling rest API calls. Initially user logged in and get a access token, I don’t know when this access token will expire so I want to implement a logic that will call, whenever I will get 401 error, that should fire a request to server to refresh the access token and try the current request again. I don’t want check 401 in every request response. I want to implement this in such a way that i don’t need to check 401 reponse code in every rest api call, if any request code is 401 then it will automically make another request to refresh the access token and try the current request again. Please help. It is last feature that need to implement and the most important thing is, I really want to learn how can I do this using RxJava.
@akarnokd thanks I made my logic today here is my blog https://medium.com/@therajanmaurya/refresh-access-token-globally-using-rxjava-2-rxandroid-2-and-retrofit-2-fba6be0f11bd
Any suggestions on how to do the following without relying on errors for control flow?
Single<RbmAccessToken> accessToken = accessTokens.get(agent);
return Single.just(accessToken)
.flatMap(t -> t == null
? Single.error(new Throwable("no token"))
: t)
.flatMap(t -> Instant.now().plusSeconds(60).isAfter(t.expiresAt())
? Single.error(new Throwable("token expired"))
: Single.just(t))
.onErrorResumeNext(t -> {
Single<RbmAccessToken> newAccessToken = getAccessToken(agent);
accessTokens.put(agent, newAccessToken);
return newAccessToken;
});
hehe, also, the above doesn't work :D
I had the following before:
if (accessToken != null && accessToken.blockingGet().expiresAt().isAfter(Instant.now().plusSeconds(60))) {
return accessToken;
}
Single<RbmAccessToken> newAccessToken = getAccessToken(agent);
accessTokens.put(agent, newAccessToken);
return newAccessToken;and was trying to get rid of the blocking get
For completness here's the current version that actually works, didn't know about null not usable as values
Single<RbmAccessToken> accessToken = accessTokens.get(agent);
return Single.just(Optional.ofNullable(accessToken))
.flatMap(t -> t.orElse(Single.error(new Throwable("no token"))))
.flatMap(t -> t.isExpired()
? Single.error(new Throwable("token expired"))
: Single.just(t))
.onErrorResumeNext(t -> {
Single<RbmAccessToken> newAccessToken = generateAccessToken(agent);
accessTokens.put(agent, newAccessToken);
return newAccessToken;
});
@perfectplayer do you mean "overrx" as in trying to do too much with rx?
Hi! Is there a way to pass the output of one Observable to the input of the second in RxJava2? My task is to get the list of users from server and then save it to the DB. I'm using Retrofit2 for API and Room as ORM on Android. Now I have this code
api.userList()
.map(new Function<List<UserDto>, List<User>>() {
@Override
public List<User> apply(@NonNull List<UserDto> userDtos) throws Exception {
return userMapper.fromDtoList(userDtos);
}
})And I need to pass List<User> that I get from map to this method in DAO
@Insert
Completable insertAll(List<User> users);
I'm accessing a db with vertx and caching the result in the observable so that all other observables can be zipped with its result. But I need to invalidate this cache. It's an api that tons of android devices are connecting to, the data I'm caching stays the same for all of them, but may be changed in the admin so vertx must reload it...
I'm currently on RxJava 1.x...
And Kotlin
Hello everyone!
How can i solve such problem.
I have
I want it to emit first received item within some window (3 seconds, for example) immediately and then skip all other items that emitted during next 3 seconds. After 3 seconds, this behaviour should repeat.
Something like this: https://codeshare.io/an4LbE
How can i solve such problem.
I have
Observable that emits items randomly. (Button clicks, for example)I want it to emit first received item within some window (3 seconds, for example) immediately and then skip all other items that emitted during next 3 seconds. After 3 seconds, this behaviour should repeat.
Something like this: https://codeshare.io/an4LbE