Questions tagged [reactive-programming]

Reactive Programming is a programming paradigm oriented around data flows and the propagation of change.

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

Java Project Reactor/WebFlux token service

I'm trying to achieve a thread-safe reactive token service. The point is that all subscribers must wait until the token is received or updated (when expired). It works, but I want a second opinion ...
John Goode's user avatar
2 votes
0 answers
42 views

Reactive objects, like in vue

I like the reactivity of vue and created a function that makes Object's reactive. Just like in vue 3 .reactive I wonder if my ...
Marc's user avatar
  • 153
1 vote
1 answer
45 views

Reactjs Component Reusability

I am working on a project in react. Where most of the data on different tabs have a table. So I design the "TableItems" component and passed the data according to the component. Right now ...
Hamid Shah's user avatar
1 vote
1 answer
435 views

Awaited store for Svelte

In my Svelte app, I need to reactively fetch data from the server and then render the result. The ideal data struture for this is a store whose values are promises – eg. like this: ...
m93a's user avatar
  • 296
1 vote
0 answers
81 views

Idiomatic API Authentication flow with ASWebAuthentication and Combine

I'm working on an app to display statistics based on user data from a third-party service's API. The authentication flow for the service's API that I wrote works, but some parts of it feel a bit ...
Luciano's user avatar
  • 297
1 vote
1 answer
573 views

Multithreaded observer pattern in Rust

I often want to program in an event driven way, but classic implementations of the observer pattern often pose an ownership challenge, and they only get more difficult once multiple threads are ...
Blue7's user avatar
  • 383
2 votes
1 answer
224 views

UIView position updates based on device motion via RxSwift

I've created a simple function to work as a level, where the dot on screen is centered when the device is completely flat. It changes position based on device orientation. I use RxSwift to update the ...
jclasley's user avatar
  • 101
0 votes
1 answer
802 views

Refactor multiple if condition in JavaScript/TypeScript

I want to refactor this code but am wondering how I should start it. I'm not sure this code is totally against clean code or not. I'm thinking to use RxJS or a JavaScript builtin method. I'd like to ...
DigguDg's user avatar
  • 63
1 vote
2 answers
94 views

how to destructure this.props react js

I'm trying to create a component that receives an array, this component is going to show a list with props data ...
Matheus Martins's user avatar
-2 votes
1 answer
388 views

How generate a random pojo value using reactor.core.publisher.Flux and reactor.util.function.Tuples [closed]

Firstly, take in account is my first question here in CodeReview. Any purpose misuderstanding will be highly appreciated if orientaded. Scenario: I want to answer randomly a pojo (json with two ...
Jim C's user avatar
  • 115
1 vote
0 answers
277 views

Setting the token for API client generated instances in an Angular application

I am developing an Angular application who also consumes an external REST API. I am also trying the OpenAPI generator using a TypeScript template. The OK path is the following: call a method that ...
Alexei's user avatar
  • 1,824
1 vote
0 answers
83 views

Pipe ResponseSpec's Body

I'm writing a utility method which pipes given ResponseSpec's body and gives to the caller a change to read it. ...
Jin Kwon's user avatar
  • 133
1 vote
0 answers
87 views

Lightweight, modular Discord bot - tips and feedback on the code?

The full project is up on GitHub. The codebase is super small as it stands. I'm brand new to reactive programming and Spring, and would mostly like insight on those two things. Asynchronous ...
cbryant02's user avatar
  • 111
5 votes
1 answer
48 views

Merging client names into orders using RxJS

I have an API which I can't modify. I have to use data as it is. I want to join data from two separate requests where the second request is based on data from the first one. I have a working ...
Lyczos's user avatar
  • 151
3 votes
0 answers
818 views

Endless scroll in kotlin (android)

This is the code of my function to endless scrolling. It's a good practice to bind new disposable in onscroll listener? What do you think about my code? ...
KarolDevz's user avatar
7 votes
1 answer
6k views

Getting serial port list

Needed to get a local serial port list. System.IO.Ports.SerialPort.GetPortNames() returns names but not the descriptions like you can see in Device Manager: ...
Dmitry Nogin's user avatar
  • 6,131
1 vote
2 answers
2k views

Observable implementation

I have implemented a simple Observable class. I think that there is still room for improvement. Especially the fact that I have separate array to observe results ...
iOSGeek's user avatar
  • 190
3 votes
0 answers
3k views

Implementation of reactive file write from InputStream

I want to implement reactive write to file. In low level, it uses NIO and Futures. After reading this section I created this code but maybe there's more clean or less code solution. Thanks. ...
Max Grigoriev's user avatar
2 votes
0 answers
2k views

Polling implemented using reactive framework (project reactor)

I have a use case where I need to poll a certain service till all data has arrived. The service accepts a list of ids and responds with data corresponding to these ids. Data is asynchronously made ...
Dexter's user avatar
  • 415
3 votes
0 answers
151 views

React.JS functional paradigm

I have some (minimal) experience with the functional programming paradigm and I'm new to React.js and reactive programming. I'm trying to get a flavour for the React.js philosophy and I keep seeing ...
Mike's user avatar
  • 131
4 votes
1 answer
319 views

Notify user of credential failure and make another attempt

The below code works because of the do operator on line 24. Is there a more functional way to get the test to pass, or would you consider this an appropriate use of ...
Daniel T.'s user avatar
  • 821
1 vote
0 answers
2k views

Paging loader using RxSwift

This is generic logic for handling network requests that load data based on pages. It is assumed that the view controller would implement the UISource protocol. I ...
Daniel T.'s user avatar
  • 821
3 votes
1 answer
6k views

Is my implementation of a simple CRUD service with Spring WebFlux correct?

I am implementing a simple Movie based CRUD API using Spring WebFlux and Reactive Spring Data MongoDB. I want to make sure that my implementation is correct and that I am properly using Flux and Mono ...
Son Goku's user avatar
1 vote
1 answer
695 views

Line count of each file in a given directory efficiently using akka

This is my first program in akka so I wanted to know if the program is efficient and is using the advantages of actor model. The program's purpose is to scan a given directory for any files and print ...
whokares's user avatar
  • 111
2 votes
1 answer
86 views

ReactiveX observable that uses another observable

I am trying to write an Angular service that will wrap the regular Http service and automatically make authentication calls if Bearer token is not available or invalid. Here's an illustration of a ...
Igor Soloydenko's user avatar
5 votes
1 answer
168 views

Video downloader app implemented in RxJs

I have used multiple map/flatmap combinations. Could anybody help me with the review? ...
Sreevisakh's user avatar
5 votes
1 answer
2k views

Reactive Properties for easy property binding

This is my attempt to write a data-bindable, platform independent property that doesn't require any literal strings. The basic idea is to basically have the same functionality as IObservable, but with ...
Juan's user avatar
  • 655
2 votes
1 answer
6k views

ReactiveUI And WPF - Reusing a value to update multiple properties

I've created my first ReactiveUI app in WPF. Simply, the user enters their full name in one textbox, and then the name gets split into its parts and displayed in the other textboxes. This is just an ...
3-14159265358979323846264's user avatar
2 votes
1 answer
67 views

Preforming some async operations with Rx.js

I tried to come up with a good challenge to learn some Rx.js programming and I came up with this chain of operations below. As well as a bit of code that works and does these things. Take github ...
ThomasReggi's user avatar
4 votes
3 answers
543 views

Performing data transportations in RxJS with Promises

I'm using RxJS 5.0.0-alpha.12 to perform some data transformations, and some of those transformations use Promises. ...
Nathan Jones's user avatar