All Questions
Tagged with rxjs5 rxjs-observables
21
questions
2
votes
1
answer
90
views
Why does RXJS Observable stops emitting after getting error
I am trying to access datas every time the user changes the input value.
The search can return an error.
In this case, I want to disable the use of AI (semanticDisabled) for future searchs and then ...
0
votes
1
answer
33
views
rxjs 5 -> 6 migration: connect operator missing
We started upgrading rxjs from v5 to v6 (without using the compatibility layer, in case it makes any difference).
The majority of the changes are straight forward and well documented in https://github....
- 2,354
0
votes
1
answer
78
views
How to take some of the properties of an Observable and assign them to another Observable using RxJS operators
I have an employee$ Observable and a personalInformation$ Observable. personalInformation$ is a subset of employee$ and I want to map the matching properties of employee$ to personalInformation$. The ...
- 175
1
vote
0
answers
71
views
How to make my newly created observable subscribers to get a boolean?
I want to make an observable that when a subscribed to emits a boolean , i tried a lot of combinations but nothing seems to work.
example:
let myObservable = new Observable<boolean>(item => ...
- 35
0
votes
2
answers
1k
views
how to flatten the nested array in rxjs
I am using forkJoin to subscribe multiple inner observable. How can I flat nested array to single level array.
const x$ = of([1, 2, 3, 4]);
const y$ = of([2, 4]);
x$.pipe(
switchMap((t) => {
...
- 1,926
0
votes
1
answer
435
views
How can I make an Alert appear in the screen using AG Grid and Adaptable/
I created an Observable Alert in AG Grid (using Adaptable) which is correctly firing when an order is stale for 2 minutes.
But I only see the Alert in the Toolbar and not as a popup notification in ...
- 112
0
votes
1
answer
860
views
Avoiding duplicate calls inside keyup event in angular
What i am trying to do is
call a service and bind the data on ngOnit()
In the given textbox, when a user types something, instead of calling API call for every letter, wait for a second, if user ...
- 9,047
1
vote
2
answers
954
views
RxJS group by field and return new observable
I've following interfaces and Observable<Machine[]>, what I want to achive is group by Machine symbol property in Observable<Machine[]> and return mapped observable Observable<Order[]&...
- 21
1
vote
1
answer
601
views
Cancel repeated subscription in mergeMap
How to combine the distinct, switchMap and mergeMap operators, so that when the source emits repeated values (detected by distinct.keySelector), the previous subscription is canceled (as in the ...
- 724
1
vote
2
answers
1k
views
RxJS - How to incrementally increase the delay time without using interval?
I want to incrementally increase the delay for this:
const source = from(839283, 1123123, 63527, 4412454); // note: this is random
const spread = source.pipe(concatMap(value => of(value).pipe(delay(...
- 5,656
0
votes
2
answers
764
views
subscribing when mouseover on particular element in the DOM
I need to subscribe & do some actions, when mouseover on particular elements in the DOM.
For Example: home.component.html
<div class="container">
<div ...
- 161
0
votes
1
answer
247
views
rxjs : get duplicate http requests on the first set that I send
I made this functionality, each iteration i have 7 requests that sent each environment.dashboard.frequency time,
but at the beginning, I see that i send 14 requests to the server instead of 7 :
let ...
0
votes
1
answer
73
views
Confusion using Observable.switch
The switch documentation on github contains an example on how to use the command.
var source = Rx.Observable.range(0, 3)
.select(function (x) { return Rx.Observable.range(x, 3); })
.switch();
var ...
- 384
0
votes
1
answer
173
views
behaviour subject and observable in Angular8
I have get rest service data call that is called 3 times. I need to create a data service to reduce the call to once so it keeps a local copy.if the copy hasn't been populated yet, it hits the api to ...
- 183
1
vote
5
answers
611
views
How to remove the redundant requests in RXJS?
I am working on a front-end project with Rxjs and Angular Framework and I want to get json data from a api "api/data_processor_classlib.php....". There are three parts was subscribed the pipe this....
- 33