关于Observable的save方法返回EMPTY或占位值的技术咨询

最近我碰到了RxJS里一个挺常见的场景：有些返回Observable的函数（比如数据保存操作save()）不需要传递任何next()值，但又得参与到Observable的链式调用里，保证操作的顺序执行。我特意写了一个BookService的示例，用单条链式调用完成两本书的保存、获取并打印的操作，这里分享两种可行的实现方案：

方案1：返回Observable<never>类型的EMPTY #

这种方案里，save()直接返回RxJS的EMPTY对象，它的特点是订阅后不会触发next()回调，只会直接进入complete()状态。这样一来，它就能在链式调用里作为一个"无输出"的步骤，不干扰后续流的执行，同时又能保证操作的顺序。

示例代码 #

import { Injectable } from '@angular/core';
import { Observable, EMPTY, of } from 'rxjs';
import { concatMap } from 'rxjs/operators';

@Injectable({ providedIn: 'root' })
export class BookService {
  private books: string[] = [];

  // 保存书籍，返回无next值的Observable
  save(title: string): Observable<never> {
    this.books.push(title);
    return EMPTY;
  }

  // 获取所有书籍列表
  getBooks(): Observable<string[]> {
    return of([...this.books]);
  }
}

链式调用示例 #

this.bookService.save('The Great Gatsby')
  .pipe(
    // 等待第一本保存完成，再保存第二本
    concatMap(() => this.bookService.save('1984')),
    // 等待第二本保存完成，再获取书籍列表
    concatMap(() => this.bookService.getBooks())
  )
  .subscribe({
    next: (books) => console.log('最终书籍列表:', books),
    complete: () => console.log('所有操作完成')
  });

这里用concatMap来串联操作，它会严格等待前一个Observable完成后，再执行下一个操作，完美契合我们需要的顺序执行要求。

方案2：返回Observable<void>类型 #

如果觉得Observable<never>的语义有点抽象，也可以选择让save()返回Observable<void>，用of(undefined)来明确表示这个操作没有有意义的返回值，语义上会更直观。

修改后的save()方法 #

save(title: string): Observable<void> {
  this.books.push(title);
  return of(undefined);
  // 也可以用 EMPTY.pipe(mapTo(undefined)) 实现同样效果
}

链式调用的逻辑和方案1完全一致，因为我们本来就不关心save()的返回值，只需要它执行完成即可。

一些注意事项 #

• 别用tap代替concatMap：如果save()是异步操作（比如实际项目里的HTTP接口调用），tap不会等待异步操作完成就会执行后续逻辑，会导致操作顺序混乱。而concatMap/switchMap这类操作符会等待前一个Observable完成后再继续，能保证顺序。
• 异步场景适配：如果你的save()是异步的（比如HTTP POST请求），只需要把示例里的同步push换成HTTP请求Observable即可，链式调用的逻辑不需要任何修改。

内容的提问来源于stack exchange，提问作者kctang