for i in inputs_init:
        # Subscribe to input topic
        Ir = Subject()
        i["msg"] = Ir