rxpy operators the rx operators flat_map(operator also applies function to each data item but then applies flatten operation to the result for exampleif the result is list of lists then flat_map will flatten this into single list in this section we will focus on the rx operators map(operator the rx operators map(operator allows function to be applied to all data items generated by an observable the result of this function is then returned as the result of the map(operators observable the function is typically used to perform some form of transformation to the data supplied to it this could be adding one to all integer valuesconverting the format of the data from xml to jsonenriching the data with additional information such as the time the data was acquired and who the data was supplied by etc in the example given below we are transforming the set of integer values supplied by the original observable into strings in the diagram these strings include quotes around them to highlight they are in fact stringthis is typical of the use of transformation operatorthat is to change the data from one format to another or to add information to the data the code used to implement this scenario is given below note the use of the pipe(method to apply the operator to the data stream generated by the observableapply transformation to data source to convert integers into strings import rx from rx import operators as op set up source with map function source rx from_list([ ]pipeop map(lambda value"'str(value"'"subscribe lambda function source subscribe(lambda valueprint('lambda received'valueis string 'isinstance(valuestr))