RxJS乐观更新(强制发出乐观值)

如何在RxJS中实现乐观更新?请看这个例子:

const todoIdSource: Subject<string> = new Subject();
const $todo = todoIdSource.pipe(
    tap(id => {
        const optimisticTodo: any = {
            userId: 1,
            id: id, // Use some value from the source observable
            title: "delectus aut autem",
            completed: false
        };
        // TODO force emit optimisticTodo! How? :)
    }),
    concatMap((id) => ajax('https://jsonplaceholder.typicode.com/todos/' + id)),
    map(response => response.response)
);

$todo.subscribe(value => console.log('TODO', value));

todoIdSource.next('1');

$todo 在ajax调用完成之前不会发出。 但我希望它在todoIdSource发出后立即发出乐观值。 最后,$todo应该发出2个值:

• 乐观值
• ajax结果的值

注:

• 乐观值不应触发ajax调用。
• 乐观值应该能够使用来自可观察源的数据 todoIdSource .

在RxJS中有没有一种优雅的方法来实现这一点?我可以想象引入第二个Observable optimisticTodo$ 然后将其与 $todo 。但这感觉并不优雅:)