Index: tests/test_dialysate_flow_sensor.py
===================================================================
diff -u
--- tests/test_dialysate_flow_sensor.py	(revision 0)
+++ tests/test_dialysate_flow_sensor.py	(revision 69aa5e13a175a24174b6d6776209a6166b595c0f)
@@ -0,0 +1,57 @@
+###########################################################################
+#
+# Copyright (c) 2021 Diality Inc. - All Rights Reserved.
+#
+# THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM, IN PART OR IN
+# WHOLE, WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
+#
+# @test_dialysate_flow_sensor.py
+#
+# @author (last) H. Nguyen
+# @date (last) 29-Oct-2021
+# @author (original) H. Nguyen
+# @date (original) 29-Oct-2021
+#
+############################################################################
+
+import sys
+sys.path.append("..")
+from dialin.dg.hemodialysis_device import DG
+from dialin.dg.dialysate_flow_sensor import DialysateFlowSensor
+from time import sleep
+
+if __name__ == "__main__":
+
+    # Create a dialysate flow object called df_object
+    df_object = DialysateFlowSensor()
+
+    sleep(2)
+
+    while True:
+        sleep(0.5)
+        print("Measured Dialysate Flow = {} mL/min".format(df_object.get_flow_rate()))
+        sleep(10)
+
+        df_object.cmd_flow_sensor_value_override(1.0)
+        sleep(10)
+        print("Measured Dialysate Flow = {} mL/min".format(df_object.get_flow_rate()))
+
+        df_object.cmd_flow_sensor_value_override(1.5)
+        sleep(10)
+        print("Measured Dialysate Flow = {} mL/min".format(df_object.get_flow_rate()))
+
+        df_object.cmd_flow_sensor_data_broadcast_interval_override(500.0)
+        sleep(10)
+
+        df_object.cmd_flow_sensor_data_broadcast_interval_override(800.0)
+        sleep(10)
+
+        df_object.cmd_flow_sensor_data_broadcast_interval_override(900.0)
+        sleep(10)
+
+
+
+
+
+
+