rxpy operators the output from this program is presented below , , , , , , notice from the output the way in which the data held in the original observables is intertwined in the output of the observable generated by the merge(operator filtering operators there are several operators in this category including rx operators filter ()rx operators first()rx operators last(and rx operators distinct(the filter(operator only allows those data items to pass through that pass some test expression defined by the function passed into the filter this function must return true or false any data item that causes the function to return true is allowed to pass through the filter for examplelet us assume that the function passed into filter(is designed to only allow even numbers through if the data stream contains the numbers and then the filter(will only emit the numbers and this is illustrated belowthe following code implements the above scenariofilter source for even numbers import rx from rx import operators as op set up source with filter source rx from_list([ ]pipeop filter(lambda valuevalue = subscribe lambda function source subscribe(lambda valueprint('lambda received'value)in the above code the rx operators filter(operator takes lambda function that will verify if the current value is even or not (note this could have been named function or method on an object etc it is applied to the data stream generated by the observable using the pipe(method the output generated by this example is