reactive-programming Questions
4
Solved
I would like to call back an async function within an Rx subscription.
E.g. like that:
public class Consumer
{
private readonly Service _service = new Service();
public ReplaySubject<string...
Farrica asked 11/4, 2014 at 8:1
2
Solved
I'm learning RxJS and Angular 2. Let's say I have a promise chain with multiple async function calls which depend on the previous one's result which looks like:
var promiseChain = new Promise((re...
Brickyard asked 12/6, 2016 at 7:42
2
Solved
I'm trying to build a simple application using java reactive extensions. I have two streams that emits temperature values continuously, I want to detect and filter out spikes of sensed temperature ...
Wadlinger asked 3/6, 2015 at 8:24
2
Following is an HTML snippet I'm using as an example:
<html>
<head>
<script src="rx.all.js"></script>
</head>
<body>
<script>
var source = new Rx.Behav...
Alger asked 19/8, 2014 at 11:15
3
What is the different between the following two executions?
Mono.justOrEmpty(someFunction())
.doOnNext(() -> doSomeTask()).subscribe();
Mono.fromCallable(() -> someFunction())
.doOnNext(()...
Gi asked 22/2, 2022 at 9:23
5
Solved
I was wondering if you know of any way to use prolog for stream processing, that is, some kind of reactive programming, or at least to let a query run on a knowledge base that is continuously updat...
Geomancer asked 16/10, 2013 at 15:40
5
Solved
As per the documentation:
Flux is a stream which can emit 0..N elements:
Flux<String> fl = Flux.just("a", "b", "c");
Mono is a stream of 0..1 elements:
Mono<String> mn = Mono...
Prince asked 27/12, 2017 at 7:57
3
Solved
At what point does the spring webflux do the subscription? Everywhere I have read that there must be a subscription otherwise no change happens. In my short time with Spring Webflux, I have never s...
Arnhem asked 23/1, 2022 at 7:41
2
Solved
I'm new to Project Reactor in Spring, and I'm not fully sure how to perform something:
I have my pipeline the pipeline returns records. All good.
But I would like to count those records and then ...
Willwilla asked 21/5, 2020 at 16:5
1
Solved
I'm trying to write a test cases for createEmployee and updateEmployee by mocking the repository class. But, it's failing with below error.
Note : Other methods for find, findAll are working fine.
...
Vicinity asked 11/1, 2022 at 15:6
3
Solved
I'm using a spring flux to send parallel requests to a service, this is very simplified version of it:
Flux.fromIterable(customers)
.flatMap { customer ->
client.call(customer)
} ...
I was...
Explanatory asked 10/8, 2018 at 12:16
2
Solved
I have a chain of Async and Sync method invocation on Mutiny's Uni, some methods are a long-running process with return type void.
What is the proper way of invoking/calling them without blocking d...
Baseline asked 14/3, 2021 at 15:31
3
Solved
I'm designing a small tool that will generate CSV test data. I want to use Akka Streams (1.0-RC4) to implement the data flow. There will be a Source that generates random numbers, a transformation ...
Up asked 13/7, 2015 at 8:46
1
Solved
Context
I started working on a new project and I've decided to move from RxJava to Kotlin Coroutines. I'm using an MVVM clean architecture, meaning that my ViewModels communicate to UseCases classe...
Sierra asked 6/12, 2021 at 14:19
2
Solved
I am new to RxSwift programming.
I am confused between the two while coding. Which one should be used to store datasource of table and how to decide that ?
Sicular asked 26/2, 2020 at 17:28
7
i'm new to react-native i installed expo as mention in official page like below.
npm install expo-cli --global
expo init my-new-project
cd my-new-project
expo start(run this in my cmd)
Get thi...
Tallulah asked 26/11, 2018 at 4:37
1
Solved
Is it possible for a RestTemplate to consume an endpoint which is reactive based (Spring WebFlux)? I understand that the main idea of reactive programming is to avoid blocking and make better use o...
Mahdi asked 14/11, 2021 at 0:33
3
The examples in the RxJS README seem to suggest we have to subscribe to a source. In other words: we wait for the source to send events. In that sense, sources seem to be push-based: the source dec...
Centralia asked 11/11, 2015 at 22:47
1
Solved
Is it possible to use the Using operator in Rx.Net with a resource that implements IAsyncDisposable rather than IDisposable? If not, is there some sort of workaround that I could use?
Vardon asked 1/11, 2021 at 15:43
1
I'm using spring boot webflux + project reactor + lettuce for connecting and querying Redis in a non blocking way.
I have configured the ReactiveRedisTemplate with LettuceConnectionFactory. The spr...
Merchantable asked 15/8, 2018 at 21:4
3
Looking for converting Flux to List<Object>. Getting error if I use block(). So, need to conver without blocking calls.
Flux.from(Collection.find())
Using reactive programming, but graphq...
Adrastus asked 31/5, 2020 at 1:40
7
Solved
The typical solution to the problem doesn't work in in React due to
its dynamically generated component structure and event model, as opposed to
traditional static HTML:
script:
<script>
...
Millner asked 4/2, 2017 at 16:47
1
This is a super simple question, yet it bothers me that I am not completely understanding what is happening here, because I really like svelte and want to understand it.
There is this awesome video...
Achromat asked 9/10, 2021 at 8:30
1
Solved
The following code attempts to react to one Supply and then, based on the content of some message, change its mind and react to messages from a different Supply. It's an attempt to provide similar ...
Dunite asked 7/10, 2021 at 3:48
1
Solved
I am trying to create a table (with DT, pls don't use rhandsontable) which has few existing columns, one selectinput column (where each row will have options to choose) and finally another column w...
Isiahisiahi asked 27/9, 2021 at 10:19
© 2022 - 2024 — McMap. All rights reserved.