FilterAndTake example to answer (http://stackoverflow.com/questions/25165780/rx-java-operators-encapsulating-data-flow-into-custom-operators)