reactive-extensions-js Questions
3
Solved
I want to start learning Rx.js and I'm looking for a cool example to start the ball rolling. How do I detect konami code with Rx.js?
I want to detect a sequence of key press events (up up down dow...
Stability asked 2/12, 2010 at 15:31
4
Solved
JSBIN Sample
I have a changeable set of child components (POJO object) that each have its own state stream. Each time a user triggers addChild/removeChild/clearChildren, a new set of children stat...
Letitialetizia asked 30/8, 2016 at 15:17
3
I have two behaviour subject streams what I'm trying to forkJoin with no luck.
As I imagined it gives back the two last values of it. Is this possible to implement it somehow?
It is not called aft...
Tanika asked 27/9, 2016 at 10:36
4
Solved
I have two observables:
An observable representing a list of checkbox inputs.
An observable representing a stream of events coming from the server.
I'd like to filter the second observable usin...
Tucci asked 19/7, 2013 at 11:54
7
I am trying to convert my promise based code to RxJs but have a hard time to get my head around Rx especially RxJs.
I have a an array with paths.
var paths = ["imagePath1","imagePath2"];
And I ...
Scaleboard asked 12/7, 2015 at 10:21
3
Solved
Why doesn't the flatMap cause downstream reductions to fire?
I got code like:
handleFiles.flatMap(files =>
Rx.Observable.from(files).
flatMap((file, i) => fileReader(file, i)).
reduce((f...
Phototypy asked 8/11, 2015 at 16:4
5
Solved
How do i execute the following scenario in the browser with RxJs:
submit data to queue for processing
get back the job id
poll another endpoint every 1s until result is available or 60seconds hav...
Cannon asked 15/3, 2016 at 9:56
6
Solved
I try to chain multiple rx.js observables and pass the data. Flatmap should be the fitting operator but with an import of
import { Observable } from 'rxjs/Observable';
it is not found:
Error TS...
Bastian asked 20/7, 2016 at 12:46
4
Solved
I have a service which returns data in pages. The response to one page contains details on how to query for the next page.
My approach is to return the response data and then immediately concat a ...
Tsaritsyn asked 16/12, 2014 at 21:33
4
Solved
fromArray Rx wiki on github
coffee> rext = require 'rx'
coffee> arr = [1..5]
[ 1, 2, 3, 4, 5 ]
coffee> obs = rext.Observable.fromArray(arr)
{ _subscribe: [Function] }
coffee> obs....
Symphysis asked 22/1, 2013 at 19:17
1
Solved
The following code emits an int after 5000ms and then another in every 5000ms later:
let evens = Observable.interval(5000)
.map(i => {
return i * 2;
});
evens.subscribe((i) => {
consol...
Slumberland asked 7/3, 2017 at 11:49
1
Solved
I am doing some http requests and use rxjs for successfull notification of the result:
getReportings(departmentId: number): Observable<any> {
return Observable.forkJoin(
this.http.get('/a...
Crowther asked 17/12, 2016 at 23:29
3
I have a hot observable (a subject in this case):
var subject = new Rx.Subject();
I want to create another observable that every time a new subscriptions is being made immediately fires out th...
Chefoo asked 16/3, 2012 at 10:40
1
I'm struggling to get my head around the "Rx" way of displaying a loading indicator for an AJAX stream.
$scope.$createObservableFunction("load")
.take(1)
.do(function(){
$scope.loading = true;
...
Penetrant asked 13/4, 2015 at 13:45
2
Solved
I'm using AngularJS 2 Beta 0 and I'm trying to create an RxJS Observable from an event on a window object. I believe I know the formula for capturing the event as an Observable in my service:
var ...
Rickettsia asked 21/12, 2015 at 13:44
3
Solved
RxJs stops listening to click events when an inner observable errors (Ajax request). I'm trying to figure out how to keep the event listener hooked to the button click event and gracefully handle t...
Agrapha asked 21/7, 2014 at 1:45
1
Solved
What is the cleanest way to perform a side-effect when the last subscription for a RxJS Observable is disposed? This may occur before the Observable has terminated.
Let's say that I need a functio...
Thanos asked 26/10, 2015 at 19:19
3
Solved
I've got a special producer consumer problem in RxJS: The producer slowly produces elements. A consumer is requesting elements and often has to wait for the producer. This can be achieved by zippin...
Impost asked 26/2, 2015 at 17:22
2
Solved
Disclaimer: it is the continuation for the previous Safe update for 2 dependent streams question
What is the idiomatic way to handle errors in RxJS (or any other RX implementation) that allows the...
Paradiddle asked 24/12, 2014 at 1:59
4
Solved
As an exercise I'm trying to build 2 dependent streams which update one another.
The test application is simply an "Inches <-> Centimeters" converter, with both inputs editable.
The issue I am...
Disavowal asked 22/12, 2014 at 4:43
1
Solved
Unlike other "FRP" libraries, Rx doesn't prevent glitches: callbacks invoked with time-mismatched data. Is there a good way to work around this?
As an example, imagine that we have a series of exp...
Gaona asked 11/3, 2014 at 17:39
1
Is it possible to split a single observable flux in multiple other observables?
My use case is a form that a user can submit. The submit action is handled in an observable, and on this action, the...
Fritts asked 6/7, 2014 at 7:27
3
Solved
I'm trying to set up the update loop of a simple game, built with observables in mind. The top-level components are a model, which takes input commands, and produces updates; and a view, which disp...
Hardboard asked 8/6, 2014 at 15:19
1
Solved
Is there any solution like following one for RxJS?
Is it possible to invoke subscribers's OnNexts on different threads in Rx?
P.S. My first, naive approach(in CoffeeScript) had obviously faile...
Ocher asked 29/8, 2012 at 14:4
0
Following up on How to structure rxjs code, concerning how to structure a widget with subwidget when using rx, how would you structure rx code where the subwidgets are data-driven?
As a toy proble...
Riedel asked 4/3, 2014 at 23:1
1 Next >
© 2022 - 2024 — McMap. All rights reserved.