Writing an RxCpp operator as a Lambda