'"Test the setup with subscription.'

def test_setup_with_pub(self):

    assert (self.hass.bus.listeners.get('*') is None)
    assert self.add_eventstream(pub_topic='bar')
    self.hass.block_till_done()
    assert (self.hass.bus.listeners.get('*') == 1)
