Intermédiaire
L'exemple si dessous nous montre quelle pratique sous RxJS ?
const request = interval(1000);
function takeOnlyPairAndSum(
max: number
): UnaryFunction<Observable<number>, Observable<number>> {
return pipe(
filter((val) => val % 2 == 0),
reduce((acc, value) => acc + value),
tap(x => console.log(x)),
);
}
request.pipe(takeOnlyPairAndSum(10)).subscribe();
Auteur: Amine BouchamStatut : PubliéeQuestion passée 16 fois
Modifier
0
Évaluations de la communautéPersonne n'a encore évalué cette question, soyez le premier !
Questions similairesPlus de questions sur RxJS
0
Expliquez la différence entre un Subject et un BehaviorSubject en RxJS0
Pourquoi utiliser RxJS ?0
Pourquoi est-il important de se désabonner dans RxJS?0
Est-il important d'utiliser unsubscribe sur l'opérateur forkJoin?0
Comment est appelée cette façon de faire ?
```ts
interface UserData {
[key: string]: any;
}
class UserDataService {
private userData: BehaviorSubject<UserData> = new BehaviorSubject({});
private userData$: Observable<UserData> = this.userData.asObservable();
public setUserData(userData: UserData) {
this.userData.next(userData);
}
public getUserData(): Observable<UserData> {
return this.userData$;
}
public getUserDataByKey(key: string) {
return this.userData$.pipe(map((userData) => userData[key]));
}
}
```