how you could create a custom RXJS operator which can replace the repetitive operators used across multiple methods.