All Questions
12 questions
0
votes
1
answer
316
views
RxJS Filtered/Grouped Debounce
I'm trying to use the RxJS debounce operator, but I want to customize when the emissions from the source are debounced.
By default, any emission from the source inside the debounce window will cause ...
- 1,306
1
vote
1
answer
440
views
Need to execute async function for every element of the array but dispatch action with progress only
I am quite new in RxJS, still trying to figure out how to implement different features using it.
I need help regarding the implementation of an observable, tried so many ways but none seems to work.
I ...
- 59
0
votes
1
answer
647
views
How to write marble test for this custom RxJS operator used in redux-observalbe Epic
I need to write marble test for my custom operator used in this loadEpic epic - this helps me to avoid problems that action INITIALiZE sometimes is dispatched to late and i getting LOAD_FAILURE:
...
- 5
0
votes
2
answers
385
views
Redux-Observable - Cancel next request if it has same parameters with current one, but let it run when they are different
I'm new to reactive programming. Just trying to understand observables and rxjs operators. I have a react-redux application that has a custom middleware to handle cached data and isFetching flags. ...
- 1,052
1
vote
1
answer
680
views
Redux Observable Epic conditional statement using RXJS
I am trying to achieve a particular scenario by writing an epic in redux-observable.
Elements in View
A dropdown: Dropdown has countries,
A Text box : has the user name field
A Checkbox : user ...
- 443
0
votes
1
answer
53
views
retry does not cause ajax call to be retried when Observable is retried
Based on redux-observable I have this epic:
export const someEpic = action$ => {
return action$.pipe(
ofType('FETCH_DATA'),
switchMap(({ payload: { filter, bookingCenter } }) => {
...
- 17.8k
0
votes
1
answer
1k
views
Source.pipe is not a function with redux-observable / rxjs/operators
Handling a react-native redux-observable project (*sigh...).
On the configuration of the store it seems I have an error but for the life of my I cannot know why.
Getting the following screen on load.
...
- 7,463
1
vote
1
answer
212
views
In Redux Observable how to get image size after img has loaded
I'm trying to get the dimensions of an image after it has loaded. I've received the URL from an api response, created an image instance and onload I want to dispatch the GET_IMAGE_DIMENSIONS action ...
- 537
0
votes
1
answer
633
views
Skipping observable emissions after first pending one
var button = document.querySelector('button');
var obs1 = Rx.Observable.fromEvent(button, 'click').scan(count => count + 1, 0).multicast(new Rx.Subject())
function obs2$(result) {
return ...
- 6,050
0
votes
1
answer
3k
views
Rxjs OR operator
I am trying to implement or operator with rxjs. is Race function is for OR operator.
code exmaple:
export function saveComment(action$) {
return race(
action$.ofType(COMMENT....
- 342
0
votes
0
answers
236
views
get error on combineLatest to mapTo
export function handleAction(action$) {
return combineLatest(
action$.ofType(actions.LAYOUT_READY),
action$.ofType(actions.LOADING))
.mapTo(...
- 342
0
votes
1
answer
311
views
How can I escape a catch chain early with rxjs?
I made a wrapper for accessing the 'rxjs/observable/dom/ajax' functions with an authentication header. That part went ok.
export const authjax = {
create: urlOrRequest => ajax(typeof ...
- 75