Converting an arbitrary Lambda to a custom Rx operator