def setUp(self): super(TestStream, self).setUp() if os.path.exists(_pipepath): os.unlink(_pipepath) os.mkfifo(_pipepath)