Enables to execute RxJS operators after each other. Applied on

fruits.pipe(
 
distinct()
 
).subscribe(fruit => toConveyorBelt(fruit));

Can be used nicely with: