def METHOD_NAME(self):
    self.loop.run_until_complete(self.client.sio.emit('join', {'room': SAMPLE_TOPIC}))
    EventWriter().write_event(SAMPLE_EVENT)
    self.loop.run_until_complete(asyncio.sleep(TIMEOUT))
    self.assertEqual(len(self.client.events), 1)