summaryrefslogtreecommitdiff
path: root/tests/test_buffered_pipe.py
diff options
context:
space:
mode:
authorScott Maxwell <scott@codecobblers.com>2013-11-02 20:18:18 -0700
committerScott Maxwell <scott@codecobblers.com>2013-11-02 20:19:04 -0700
commit7444a999931cddc1e61bb35270468aa45da2687e (patch)
tree1ac60cc2d3a949285e3a4917c05c19a6d03c775d /tests/test_buffered_pipe.py
parent45e65b6e1eb47944a26e4349d41998844c155df5 (diff)
downloadparamiko-7444a999931cddc1e61bb35270468aa45da2687e.tar.gz
Fix some deprecation and resource warnings
Diffstat (limited to 'tests/test_buffered_pipe.py')
-rw-r--r--tests/test_buffered_pipe.py28
1 files changed, 14 insertions, 14 deletions
diff --git a/tests/test_buffered_pipe.py b/tests/test_buffered_pipe.py
index 7f48b705..5a088d80 100644
--- a/tests/test_buffered_pipe.py
+++ b/tests/test_buffered_pipe.py
@@ -45,39 +45,39 @@ def close_thread(pipe):
class BufferedPipeTest(ParamikoTest):
def test_1_buffered_pipe(self):
p = BufferedPipe()
- self.assert_(not p.read_ready())
+ self.assertTrue(not p.read_ready())
p.feed('hello.')
- self.assert_(p.read_ready())
+ self.assertTrue(p.read_ready())
data = p.read(6)
- self.assertEquals(b('hello.'), data)
+ self.assertEqual(b('hello.'), data)
p.feed('plus/minus')
- self.assertEquals(b('plu'), p.read(3))
- self.assertEquals(b('s/m'), p.read(3))
- self.assertEquals(b('inus'), p.read(4))
+ self.assertEqual(b('plu'), p.read(3))
+ self.assertEqual(b('s/m'), p.read(3))
+ self.assertEqual(b('inus'), p.read(4))
p.close()
- self.assert_(not p.read_ready())
- self.assertEquals(b(''), p.read(1))
+ self.assertTrue(not p.read_ready())
+ self.assertEqual(b(''), p.read(1))
def test_2_delay(self):
p = BufferedPipe()
- self.assert_(not p.read_ready())
+ self.assertTrue(not p.read_ready())
threading.Thread(target=delay_thread, args=(p,)).start()
- self.assertEquals(b('a'), p.read(1, 0.1))
+ self.assertEqual(b('a'), p.read(1, 0.1))
try:
p.read(1, 0.1)
- self.assert_(False)
+ self.assertTrue(False)
except PipeTimeout:
pass
- self.assertEquals(b('b'), p.read(1, 1.0))
- self.assertEquals(b(''), p.read(1))
+ self.assertEqual(b('b'), p.read(1, 1.0))
+ self.assertEqual(b(''), p.read(1))
def test_3_close_while_reading(self):
p = BufferedPipe()
threading.Thread(target=close_thread, args=(p,)).start()
data = p.read(1, 1.0)
- self.assertEquals(b(''), data)
+ self.assertEqual(b(''), data)
def test_4_or_pipe(self):
p = pipe.make_pipe()