Wsrtjtyk

I am trying to merge 3 different observables and identify them as source value. Also I am getting userDetails in withLatestfrom so that I can do operation depending on which observable got triggered (username - u, password - p, age - a). I am confident that there is something wrong in the fact that I am putting map functions inside of Observable.merge and that is why no matter which Observable was supposed to trigger my source is always 'u' in "switch case" statement.

@Effect

public test = Observable.merge(

  this.onUserNameUpdate().pipe(

    map(() => 'u')),

    this.onPasswordUpdate().pipe(

      map(() => 'p')), 

      this.onAgeUpdate().pipe(map(() => 'a')))

        .withLatestFrom(this.store.select(getUserDetails),

      (source, userDetails) => ({

        source,

        order

      })

  )

  .map((params) => {

    switch (params.source) {

      case 'u':

        // do smth with username

      case 'p':

        // do smth with password

      case 'a':

        // do smth with age

    }

    return {

      // some object

    }

  })

Could anyone explain what am I doing wrong here?

Please try to replace first mixed (pipe and observable operators) part with some pure RxJS 5 array of observables:

public test = Observable

.merge(

  this.onUserNameUpdate()

  .map(v => 'u'),

  this.onPasswordUpdate()

  .map(v => 'p'),

  this.onAgeUpdate()

  .map(v => 'a')

)

And see If your switch/case is moving accordingly.

As well I see you are getting additional user details depending on what source observable triggered action, I'd enclose this in concatMap:

.concatMap((trigger) => {

    return this.store.select(getUserDetails)

    .map(user => {

       let ret = user;

       ret.trigger = trigger;;

    })

})

In the end you got user info with metadata od what triggered change

EDIT

As a result of above code your stream shall be something like this:

Each onXXXUpdate function that emits observable as a result is merged using merge operator:
http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#static-method-merge

Because merge operator returns single observable that is capable of emitting every value type that it's "child" observables are emitting, in next operator concatMap we map each value emitted (regardless of it's source) to new observable that is created as output from this.store.select(getUserDetails) (I assumed this function returns observable, isn't it?). To keep track of what is the trigger we append this information as meta-data into user info response via map. Afterwards, in final operator we shall have user info with trigger information that helps to distinguish, what actions shall be taken.