You can implement your own Observable operators. This page shows you how. If your operator is designed to act on the individual items emitted by a source Observable, follow the instructions under ...