小编Hir*_*ein的帖子

消费者抵消是在消费者组级别还是在该消费者组内的单个消费者进行管理?

我试图找出消费者群体层面是否也存在任何抵消。消费者偏移量是在消费者组级别还是在 Kafka 中该消费者组内的单个消费者?

apache-kafka kafka-consumer-api

5
推荐指数
1
解决办法
958
查看次数

将过滤器应用于 Observable

我们如何将过滤器应用于Observable以便我们可以根据某些条件获取数据?我的要求是我想从userObservable 中过滤掉状态为“已批准”的用户。

下面是我的http服务方法。

getUserList(){
    return this.httpClient.get<UserModel[]>(environment.userListUrl);
}
Run Code Online (Sandbox Code Playgroud)

下面是用户模型

export class UserModel{
   userName: string;
   userStatus: string;
}
Run Code Online (Sandbox Code Playgroud)

这就是我想要做的,但不确定如何应用过滤器,以便我可以获取userStatus为“已批准”的用户

const userObservable$: Observable<UserModel[]>=this.userService.getUserList(this.cmpnyId);
observable$.pipe(filter(....<Need help here>));
Run Code Online (Sandbox Code Playgroud)

observable typescript angular

1
推荐指数
1
解决办法
235
查看次数