reactive-programming Questions
2
Solved
I am looking at some examples of reactive web applications and i am seeing them like this
@RequestMapping(value = "/{id}", method = RequestMethod.GET)
@ResponseBody
public Mono<Person> find...
Duncan asked 7/6, 2019 at 2:58
1
Solved
I am working on a Flux of some object lets say Flux < MovieReservation > . This contains info like movie id,name, timing, title etc. So I wanted to extract the info that can help in creating ...
Hassan asked 7/6, 2019 at 13:3
5
Solved
I have Observable stream, and I want to convert it to Completable, how I could do that?
Griffie asked 3/11, 2016 at 10:40
2
Solved
I want to combine result form two Mono based on some condition. Both Mono are results of WebClient calls:
The first one is a single call expecting fast response.
The second one is a combination o...
Sheelagh asked 15/5, 2019 at 11:40
3
Solved
in my project I want to have multiple clients connecting to a service. I am using the java Rsocket implementation.
The service should maintain a state for each client. Now at this point I either ...
Highkeyed asked 3/5, 2019 at 11:15
3
Solved
So in Rxjs, I have bunch of code,
return Observable.from(input_array)
.concatMap((item)=>{
//this part emits an Observable.of<string> for each item in the input_array
})
.scan((output...
Clasp asked 18/2, 2017 at 6:0
5
Is there a way to launch the Google SignIn programmatically without pressing on the GIDSignInButton ?
I'm trying to wrap a signal around hitting google api where the user must log in.
sort of :
...
Unseal asked 14/7, 2015 at 17:57
2
Solved
How can I retrieve the latest value from BehaviorSubject on RxAndroid?
Some background info: I'm using RxJava to implement MVVM pattern. My ViewModel encapsulates "bindable properties" that are Be...
Necropolis asked 6/6, 2015 at 18:44
4
Solved
Consider this code:
Mono.just(myVar)
.flatMap(MyClass::heavyOperation)
.flatMap(MyClass::anotherHeavyOperation)
.flatMap(res -> doSomething(res, MyClass.heavyOperation(myVar)));
I don't wa...
Carillonneur asked 16/4, 2019 at 8:54
2
Solved
Recently I heard the term reactive programming a lot, but when I searched for it, what I discovered was only some similarities with observer pattern. Actually, I cannot find any differences between...
Injured asked 20/5, 2013 at 15:21
2
We have a flow which we would like to implement with Reactive programming using Spring Boot 2 WebFlux. Currently we have no experience with Reactive programming.
As part of this flow we are going ...
Wrangler asked 23/10, 2018 at 9:31
2
Solved
as per the definition of the switchMap
On each emission the previous inner observable (the result of the
function you supplied) is cancelled and the new observable is
subscribed. You can remem...
Eureetloir asked 5/4, 2019 at 8:9
1
I'm developing a reactive service and preparing to use the WebClient to exchange with HTTP APIs,but the service is not in a reactive web stack so how can I use it(WebClient) without depending on We...
Unstressed asked 30/3, 2019 at 13:51
2
Solved
I want to do the following via Spring WebFlux and a given REST-API:
Retrieve a list of file names (GET /files)
Delete each retrieved file (DELETE /files/local/{file name} for each)
The problem ...
Crossbar asked 17/3, 2019 at 11:17
2
Solved
I have a use case where I need an Observable to skip its next emission whenever another notifier Observable emits.
source: |---X---X---X---X---X---X---X---X---X---X--|>
notifier: |-------------...
Parallax asked 3/7, 2017 at 14:15
1
I'm curious who started ReactiveX / RxJS?
Rx seems to be implemented in a lot of languages/platforms, I'm curious to what's the origins of it? Which project was first?
RxJS is used heavily in An...
Broad asked 10/3, 2019 at 17:5
6
Solved
I have a RxJS5 pipeline looks like this
Rx.Observable.from([2, 3, 4, 5, 6])
.takeWhile((v) => { v !== 4 })
I want to keep the subscription until I see 4, but I want to last element 4 also to...
Jerz asked 19/6, 2017 at 23:4
4
Solved
I've been using Rx on a new financial analysis project that receives all data asynchronously. I've been pretty amazed at my personal productivity and how much more understandable my event based cod...
Popish asked 15/1, 2010 at 23:49
1
I am fairly new to React and React native, but I have bumped into a problem when populating a SectionList and could not find a solution yet.
I have an array of objects, and each object has it's ow...
Swordplay asked 24/7, 2018 at 6:2
1
Solved
I am a newbie to Spring WebFlux and trying to convert my spring MVC application to webflux. I return a Mono mono from my service :
List<Store> stores = new ArrayList();
When I do:
mono...
Vermiculation asked 12/2, 2019 at 10:25
1
Solved
RxJs version 5.5 introduced the pipe operator to make it easier to combine RxJs operators and to make tree shaking more efficient for these situations. My question is, should you use the pipe opera...
Groundmass asked 5/2, 2019 at 16:24
4
Solved
From picture to code?
How to get the Out observable from Data and Gates?
Data is an observable of any kind e.g. JSON objects to be sent to a remote backend
Gates is a boolean observable, where...
Takeover asked 11/5, 2017 at 10:28
6
Solved
I have used Redux-Saga. Code written with it is easy to reason so far, except JS generator function is messing up my head from time to time. From my understanding, Redux-Observable can achieve the ...
Namangan asked 13/10, 2016 at 12:42
1
Solved
I am trying to implement bloc pattern in rxdart . I am trying to build todo app type of app . I implemented showing all items in list but what I want is not to show completed and uncompleted items ...
Byler asked 3/2, 2019 at 5:44
3
I am totally new to RxJava and reactive programming.
I have an assignment where i must read file and store it to Observable. I have tried to make a Callable with BufferedReader inside and use Obse...
Dannie asked 16/4, 2017 at 21:45
© 2022 - 2024 — McMap. All rights reserved.