import sys
import time
sys.path.append("..")
from dialin import HD, AbstractObserver


class Observer(AbstractObserver):

    def update(self, result):
        print(result)

def run():
    """
    Test if DG monitors valve states within every 500 ms
    """
    hd = HD(log_level="DEBUG")
    observer = Observer()
    hd.bloodflow.attach(observer)

    while True:
        print("Listening...")
        time.sleep(1)


if __name__ == "__main__":
    run()