How to implement following using rxjs Observables?

Question

How can I implement the following code using Observables in rxjs?

What I am trying to achieve here is that I have an array of functions, each of which accepts an object, modifies it and returns the object to the next function in the stack.

function A(res:SomeType){
    //Do Something
    return res;
}

function B(res:SomeType){
    //Do Something
    return res;
}

function C(res:SomeType){
    //Do Something
    return res;
}

let fnPipe = [];

fnPipe.push(A); 
fnPipe.push(B);
fnPipe.push(C);

obj= {key:"val"};

fnPipe.forEach((fn)=>{
    obj= fn(obj);
});
console.log(obj);

How can I implement the same using observables in rxjs?

I really don't understand why you'd do that with observable

maxime1992
– maxime1992

2017-06-19 11:19:46 +00:00
Commented Jun 19, 2017 at 11:19 — maxime1992
– maxime1992, Commented Jun 19, 2017 at 11:19

Federico Galassi · Accepted Answer · 2017-06-19 16:40:02Z

1

let fn$ = Observable.from([
  x => x + "a",
  x => x + "b",
  x => x + "c"
])
let value$ = Observable.of("x", "y", "z")

value$
  .concatMap(val => fn$.scan((acc, fun) => fun(acc), val))
  .subscribe(console.log)

/* prints
"xa"
"xab"
"xabc"
"ya"
"yab"
"yabc"
"za"
"zab"
"zabc" */

answered Jun 19, 2017 at 16:40

Federico Galassi

6826 silver badges9 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to implement following using rxjs Observables?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related