代码之家 › 专栏 › 技术社区 › Wolf359

rxjs:如果发出的值为空,则条件switchmap

rxjs angular

Wolf359 · 技术社区 · 6 年前

我有这个密码:

const id = 1; // id = 2

of([{id: 1, name: 'abc'}]).pipe(
            map(items => items.find(item => item.id === id)),
            switchMap(item => item ? of(item) : this.makeHttpRequest(id))
        );

makeHttpRequest(id: number): Observable<IdNamePair>{}

简而言之,

如果在数组中找到具有特定ID的对象,则返回Observable 的({id:1,name:'abc'})
如果在数组中找不到对象,则返回Observable
this.makehttprequest(id)方法

我想取消of(item)运算符。

这段代码可以工作,但是有没有一种方法不创建一个新的可观察对象并重用由“map()”创建的对象?

编辑:

export class MyService {
    private _list = new BehaviorSubject([{id: 1, name: 'abc'}]);
    list = this._list.asObservable();

    findOne(id: number) {
        this.list.pipe(
                    map(items => items.find(item => item.id === id)),
                    switchMap(item => item ? of(item) : this.makeHttpRequest(id))
                );
    }
}

在角度分量中:

export class MyComponent {

    item$: Observable<IdNamePair>;

    constructor(private service: MyService) {}

    ngOnInit() {
            this.item$ = this.service.findOne(1); // or (2), id comes from router
    }
}

1 回复 | 直到 6 年前

dsych 6 年前

你可以

const id = 1; // id = 2

const [hasItem, noItem] = of([{id: 1, name: 'abc'}]).pipe(
            map(items => items.find(item => item.id === id)),
            partition(Boolean)
        );

const res = merge(hasItem, noItem.pipe(switchMapTo(this.makeHttpRequest(id))

推荐文章

Fahad Subzwari · 我不能用rxjs过滤器过滤记录?

2 年前

Fazla Elahi Md Jubayer · 在rxjs中使用管道内的两个concatmap时,如何提取订阅块内的结果

2 年前

Irakli · 我想以角度显示id相似的数据

3 年前

Akash · 当BehaviorSubject发出两次真值时,使ngOnChange被激发

6 年前

Shamshiel · 将rxjs升级到6后,类型“Observable”上不存在属性“map”

6 年前

Corey Cole Roberto Tyley · 使用RxJS 6。x WebSocketSubject客户端

6 年前

gog · 如何观察rxjs中的属性更改?

6 年前

jesdynf · 在继续之前,如何使角度拦截器延迟?

6 年前

Sean Ivins · 角度2+HttpIntercept:在返回intercept函数之前,等待来自服务器的令牌

6 年前

Kevin Kalitowski · RxJs 6:从Observable获取ConnectableObservable

6 年前