reactive-programming Questions
1
The log() method in Flux.class for Project Reactor mentions that if slf4j is available, it will be used. If you use a logger implementation like logback with slf4j, they are by default blocking, es...
Sacring asked 10/8, 2018 at 2:49
2
I followed that tutorial (specifically the part with the Browser WebSocket Client): http://www.baeldung.com/spring-5-reactive-websockets
Everything works fine.
I would like to go a step further an...
Filings asked 13/2, 2018 at 9:12
2
Solved
I'm busy with Reactive concept these days. I have understood two separate concepts as Reactive System and Reactive Programming. In addition, I know Reactive System is a larger concept which contain...
Bellda asked 16/8, 2018 at 6:31
2
Solved
My current Android Application employs Retrofit and RxJava to choreograph my network calls.
I have modelled my HTTP GET(s) as Single<Response<String>> and POST(s) as Completable.
The ...
Waac asked 10/8, 2018 at 7:49
4
Solved
The R Shiny website has a great example of how to update the labels and values of a variety of input types based on user input. However, I couldn't find anything for buttons. Specifically, how do I...
Avlona asked 6/12, 2014 at 0:38
2
Solved
I'm using mousemove event to create an observable.
Observable.fromEvent(document, 'mousemove')
I need to emit every 10-th event. What do I do?
Denude asked 20/3, 2017 at 12:59
2
Solved
Is there any way of counting the amount of elements that have already been processed in a stream in RxAndroid?
I am having something like that:
Observable.fromArray(new String[]{"these", "are", "...
Parmenides asked 18/3, 2017 at 11:19
1
Solved
I have been using Subjects in Rxjava for quite awhile but today a new term came up:
PublishProccessor would you please explain me the difference of the Processors and Subjects?
I have gone throug...
Acuate asked 25/6, 2018 at 5:4
4
Solved
In every tech talk, or in every blog post I've read about IEnumerable and IObservable I read that,
IEnumerable is pull-based structure and
IObservable is push-based structure.
I've read that with...
Celestyn asked 9/7, 2018 at 21:13
1
Solved
I get that with threads being nonblocking, we don't need to have Thread sprawl depending on N concurrent requests, but rather we put our tasks in a single event loop in our reactive web programming...
Goidelic asked 7/7, 2018 at 3:47
1
Solved
I have one question regarding how to reload a list after refresh indicator is called in Flutter, using Streams and RxDart.
Here is what I have , my model class:
class HomeState {
List<Event...
Sparklesparkler asked 19/6, 2018 at 18:10
1
Solved
In ProjectReactor or Reactive Streams, Nothing Happens Until You subscribe().
Reactive streams data flow will not happen unless until someone subscribe to it, but I see for all REST APIs like fin...
Edmonds asked 11/6, 2018 at 10:0
3
Solved
Let's say I have a event-emitting data source that I want to transform into reactive stream. Data source is bound by a resource (for example a socket that periodically sends updated state) so I wou...
Malissa asked 18/5, 2018 at 20:48
2
I want to implement Endless Scrolling functionality on RecyclerView using RxJava.
What I want: I want to fetch first 10 data from API call and display it in RecyclerView. After user scrolled down ...
Synergetic asked 15/5, 2018 at 14:7
1
Solved
I'm using Spring WebFlux WebClient to retrieve data from an external API, like this:
public WeatherWebClient() {
this.weatherWebClient = WebClient.create("http://api.openweathermap.org/data/2.5/w...
Zarathustra asked 2/6, 2018 at 17:14
1
Solved
Currently experimenting reactive programming with Spring 5.0.0.RC2, Reactor 3.1.0.M2 and Spring Boot 2.0.0.M2.
Wondering about the concurrency and threading model used by WebFlux and Reactor to pr...
Cursive asked 10/7, 2017 at 18:41
2
Solved
I've got two event streams. One is from an inductance loop, the other is an IP camera. Cars will drive over the loop and then hit the camera. I want to combine them if the events are within N milli...
Adulation asked 17/5, 2018 at 15:37
4
Solved
I'm just new in ReactJS and I have a problem. I can't solve it. It seems everything is all right, but still console puts me:
A valid React element (or null) must be returned. You may have
retu...
Telling asked 1/3, 2017 at 9:43
2
Solved
combineLatest operator returns an Observable that completes when all of the observables passed in as parameters to combineLatest complete.
Is there a way to create an Observable that behaves as th...
Pattiepattin asked 25/4, 2018 at 6:59
2
Solved
I have tried all 3 solutions suggested in what is the right way to handle errors in spring-webflux, but WebExceptionHandler is not getting called. I am using Spring Boot 2.0.0.M7. Github repo here
...
Cable asked 4/12, 2017 at 10:28
1
Solved
TL;DR I'm looking for help to implement the marble diagram below. The intention is to sort the non-sorted values to the extent possible without waiting time between scan executions.
I'm not asking...
Condorcet asked 12/4, 2018 at 18:37
1
Solved
I have one observable that I use GroupBy on to get a number of streams. I actually want a Scan result over each sub-stream. Let's say the observable is over product prices and the scan result is av...
Fellini asked 17/4, 2018 at 14:24
4
Android Studio 3.2 Canary 8
com.squareup:otto:1.3.8
io.reactivex:rxjava:1.3.7
kotlin 1.2.31
I am trying to send an event back to my Activity using the otto EventBus.
However, I am using RxJava ...
Inclinable asked 6/4, 2018 at 17:4
2
Solved
I'm trying to play about with SpringBoot 2.0 and the new reactive webFlux library. I want to know how I can return the results of two calls made via the none blocking WebClient to the caller of my ...
Caruthers asked 11/4, 2018 at 18:48
1
Solved
Per the example below from the LiveData Android documentation, what would be the RxJava 2 equivalent?
We certainly can use a combination of publish(), refcount() and replay() to achieve the core o...
Athletics asked 7/4, 2018 at 15:21
© 2022 - 2024 — McMap. All rights reserved.