You can use the filter operator to filter out items from the values stream based on a result of a predicate method.
In other words, the items passing from the Observer to the Subscriber will be discarded based on the Function you pass filter, if the function returns false for a certain value, that ...