def METHOD_NAME(self):
    self.start_subscriber()
    self.assertIsNotNone(self.subscriber)
    self.assertTrue(self.subscriber.running)
    try:
        self.subscriber.stop()
    except Exception:
        self.fail("Request did not stop cleanly!")
    self.assertFalse(self.subscriber.running)
    self.assertTrue(self.subscriber.socket.closed)