def METHOD_NAME(self):
    hier = hier_block_with_message_output()
    x = block_with_message_input()
    y = block_with_message_input()
    self.tb.msg_connect(hier, "test", x, "test")
    self.tb.msg_connect(hier, "test", y, "test")
    self.run_top_block()
    self.assert_has_num_subscriptions(hier, "test", 0)
    self.assert_has_num_subscriptions(hier.block, "test", 2)
    self.assert_has_subscription(hier.block, "test", x, "test")
    self.assert_has_subscription(hier.block, "test", y, "test")
    self.tb.msg_disconnect(hier, "test", y, "test")
    self.assert_has_num_subscriptions(hier, "test", 0)
    self.assert_has_num_subscriptions(hier.block, "test", 1)
    self.assert_has_subscription(hier.block, "test", x, "test")
    self.run_top_block()
    self.tb.msg_disconnect(hier, "test", x, "test")
    self.assert_has_num_subscriptions(hier.block, "test", 0)