def setUp(self):
     BaseZMQTestCase.setUp(self)
     self.client = self.connect_client()
     # start every test with clean engine namespaces:
     self.client.clear(block=True)
     self.base_engine_count=len(self.client.ids)
     self.engines=[]

 def setUp(self):
     try:
         import tornado
     except ImportError:
         raise SkipTest("zmq.web requires tornado")
     
     BaseZMQTestCase.setUp(self)

 def tearDown(self):
     # self.client.clear(block=True)
     # close fds:
     for e in filter(lambda e: e.poll() is not None, launchers):
         launchers.remove(e)
     
     # allow flushing of incoming messages to prevent crash on socket close
     self.client.wait(timeout=2)
     # time.sleep(2)
     self.client.close()
     BaseZMQTestCase.tearDown(self)

 def tearDown(self):
     # self.client.clear(block=True)
     # close fds:
     for e in filter(lambda e: e.poll() is not None, launchers):
         launchers.remove(e)
     
     # allow flushing of incoming messages to prevent crash on socket close
     self.client.wait(timeout=2)
     # time.sleep(2)
     self.client.spin()
     self.client.close()
     BaseZMQTestCase.tearDown(self)
     # this will be redundant when pyzmq merges PR #88
     # self.context.term()
     # print tempfile.TemporaryFile().fileno(),
     # sys.stdout.flush()
     

 def setUp(self):
     BaseZMQTestCase.setUp(self)
     self.session = ss.StreamSession()

 def setUp(self):
     BaseZMQTestCase.setUp(self)
     self.client = self.connect_client()
     self.base_engine_count=len(self.client.ids)
     self.engines=[]