#2: Improve readability

Author: bednar

README.md

@@ -261,8 +261,8 @@ Read temperature every minute; distinct_until_changed - produce only if temperat
 data = rx\
     .interval(period=timedelta(seconds=60))\
     .pipe(ops.map(lambda t: sensor_temperature()),
-          ops.map(lambda temperature: line_protocol(temperature)),
-          ops.distinct_until_changed())
+          ops.distinct_until_changed(),
+          ops.map(lambda temperature: line_protocol(temperature)))
 
 _db_client = InfluxDBClient(url="http://localhost:9999/api/v2", token="my-token-123", org="my-org", debug=True)
 

influxdb2_test/iot_sensor.py

@@ -59,8 +59,8 @@ def line_protocol(temperature):
 data = rx\
     .interval(period=timedelta(seconds=60))\
     .pipe(ops.map(lambda t: sensor_temperature()),
-          ops.map(lambda temperature: line_protocol(temperature)),
-          ops.distinct_until_changed())
+          ops.distinct_until_changed(),
+          ops.map(lambda temperature: line_protocol(temperature)))
 
 _db_client = InfluxDBClient(url="http://localhost:9999/api/v2", token="my-token-123", org="my-org", debug=True)