Why`of()` observable is not executing next()?

Question

I have this situation:

 this._userService
            .create(user)
            .pipe(
                switchMap(res => {
                    if (this.accountStore.accounts.length > 0) {
                        return this._accountsService.manageAccounts(
                            accounts,
                            res.idUser
                        );
                    } else return of();
                })
            )
            .subscribe(
                _ => {
                    this._router.navigate(["/app/main/user/"]);
                },
                () => (this.saving = false)
            );

if the accounts are higher then 0, it works ok. But if it goes to the else block, the return of() doesn't execute the next() to navigate to the user route;

What am I doing wrong?

Since you don't pass arguments to `of` there is nothing to emit. — tkausl, Feb 21 '19 at 19:59
but I just would like to execute the next function without any emitted value — gog, Feb 21 '19 at 20:00
You can't. You might want to use a complete handler instead, if you're not using the value. — tkausl, Feb 21 '19 at 20:24

score 1 · Answer 1 · answered Feb 21 '19 at 21:09

1

You need to pass a value into of to execute next operator or subscriber. In this case I just pass null as of(null)

answered Feb 21 '19 at 21:09

Bunyamin Coskuner

8,719
1
28
48

score 0 · Answer 2 · 2019-02-21T20:38:40.800

0

Similar to this answer but different because of versions, you need to use the of({}).pipe(take(1)) to create an empty object observable and call next.

For your code:

...
} else return of({}).pipe(take(1));
...

edited Feb 21 '19 at 20:38

answered Feb 21 '19 at 20:02

1

but this does not emit any value at all, so still cannot hit else branch – ABOS Feb 21 '19 at 20:32
Woops, great catch. Updating – Feb 21 '19 at 20:36

score 0 · Answer 3 · edited Jun 20 '20 at 09:12

Is cleaner if you use the creational operator EMPTY

The documentation says:

Observable that immediately completes.

Creates an Observable that emits no items to the Observer and immediately emits a complete notification.

Example:

// RxJS v6+
import { EMPTY } from 'rxjs';

//output: 'Complete!'
const subscribe = EMPTY.subscribe({
  next: () => console.log('Next'),
  complete: () => console.log('Complete!')
});

stackblitz

Why`of()` observable is not executing next()?

3 Answers3