Creating a custom RxCpp operator in the library