rxjs Observable .map not executing

Question

I have the following code that returns an observable, it checks if the this.data is valid JSON, otherwise it tries to fetch it from url. The fetching and everything works.

load():Observable<IStandardListOutput[]> {

return Observable.create(observer => {

  if (this.needsFetch) {
    var data;
    this.http.get(this.data)
      .map(res => {
        var result = res.text();
        // console.log(result);
        try {
          data = JSON.parse(result)
        } catch (e) {
          return Observable.of([{error:"ERROR LOADING JSON: " + this.data}]);
        }
        return data;
      }).subscribe(res => {
        observer.next(this._parse(res));
        observer.complete();
      });
  }else {
    observer.next(this._parse(this.data));
    observer.complete();
  }
});

}

Now in the map/subscribe portion of the observer I have the following:

let observable$ = this.loader.load(); // <-- load method above
observable$.map(res => {
  console.warn ("IN MAP: " + JSON.stringify(res));
});

observable$.subscribe(res=> {
    console.log("IN SUB: " + JSON.stringify(res));
  },
  err => {
    console.log(JSON.stringify(err))
  },
  () => {
    console.info("COMPLETE")
  }
);

What I see in the output/console is only the "IN SUB" (subscribe) function and a "COMPLETE". The console.warn in the .map function is never executed.

Any help is highly appreciated, thanks in advance

Chech in here stackoverflow.com/questions/34671715/…

Amy
– Amy

2016-11-01 10:17:26 +00:00
Commented Nov 1, 2016 at 10:17 — Amy
– Amy, Commented Nov 1, 2016 at 10:17

Meir · Accepted Answer · 2016-11-01 10:14:14Z

17

The map is never executed because it creates an observable that stays cold (no subscription). Add an empty subscribe() and it should work.

observable$.map(res => {
  console.warn ("IN MAP: " + JSON.stringify(res));
}).subscribe();

And another tip on rxjs debugging, if you want to peek into the value, you can always use the do operator (instead of your map).

observable$
  .do((v) => console.log('debug point: ', v)) // <-- this is the addition.
  .subscribe(...your original handlers go here ...)

answered Nov 1, 2016 at 10:14

Meir

14.4k4 gold badges44 silver badges49 bronze badges

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

4 Comments

Fabio Antunes Over a year ago

How com your answer is different than mine, your map doesn't return anything at all

Meir Over a year ago

It sticked with the original code, just activated it. Yet, since the observable becomes hot, it will go through the map and print. If it was .subscribe(v => console.log(v)) it would present an empty value. Your example assigned observable$ = observable$.map(...) it changes the observable and the following subscription will fail.

pythic Over a year ago

okay, thank you now it works. I thought subscribing to the observable$ was enough ... (/me Observable n00b) :(

Meir Over a year ago

an rxjs noob :-) But if all you wanted was to debug print, the do() is cleaner. And actually, you don't need to .map().subscribe(), directly subscribe to it. But, making mistakes is a great way to learn.

Arthur Zennig · Accepted Answer · 2019-08-28 23:18:03Z

1

rxjs changed a lot. Angular 2 (8) is very different from AngularJS.

Since version 6 from rxjs, you need to import it with

import {map} from 'rxjs/operators';

and, in your code, include it with a pipe, for example:

observable.pipe(map(res => res.json()).subscribe( {
console.log("IN SUB: " + JSON.stringify(res)); },
  err => {
    console.log(JSON.stringify(err))},
  () => {
    console.info("COMPLETE")
  }

hope this helps!

answered Aug 28, 2019 at 23:18

Arthur Zennig

2,22227 silver badges21 bronze badges

Collectives™ on Stack Overflow

rxjs Observable .map not executing

2 Answers 2

4 Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

4 Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related