Enables to execute RxJS operators after each other. Applied on

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

Can be used nicely with: