Merge branch '2.2' into 2.3

1 files changed, 14 insertions, 13 deletions

diff --git a/tests/test_buffered_pipe.py b/tests/test_buffered_pipe.py
index eeb4d0ad..28d6e4a2 100644
--- a/tests/test_buffered_pipe.py
+++ b/tests/test_buffered_pipe.py
@@ -23,15 +23,16 @@ Some unit tests for BufferedPipe.
 import threading
 import time
 import unittest
+
 from paramiko.buffered_pipe import BufferedPipe, PipeTimeout
 from paramiko import pipe
 from paramiko.py3compat import b
 
 
 def delay_thread(p):
-    p.feed('a')
+    p.feed("a")
     time.sleep(0.5)
-    p.feed('b')
+    p.feed("b")
     p.close()
 
 
@@ -44,38 +45,38 @@ class BufferedPipeTest(unittest.TestCase):
     def test_1_buffered_pipe(self):
         p = BufferedPipe()
         self.assertTrue(not p.read_ready())
-        p.feed('hello.')
+        p.feed("hello.")
         self.assertTrue(p.read_ready())
         data = p.read(6)
-        self.assertEqual(b'hello.', data)
+        self.assertEqual(b"hello.", data)
 
-        p.feed('plus/minus')
-        self.assertEqual(b'plu', p.read(3))
-        self.assertEqual(b's/m', p.read(3))
-        self.assertEqual(b'inus', p.read(4))
+        p.feed("plus/minus")
+        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.assertTrue(not p.read_ready())
-        self.assertEqual(b'', p.read(1))
+        self.assertEqual(b"", p.read(1))
 
     def test_2_delay(self):
         p = BufferedPipe()
         self.assertTrue(not p.read_ready())
         threading.Thread(target=delay_thread, args=(p,)).start()
-        self.assertEqual(b'a', p.read(1, 0.1))
+        self.assertEqual(b"a", p.read(1, 0.1))
         try:
             p.read(1, 0.1)
             self.assertTrue(False)
         except PipeTimeout:
             pass
-        self.assertEqual(b'b', p.read(1, 1.0))
-        self.assertEqual(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.assertEqual(b'', data)
+        self.assertEqual(b"", data)
 
     def test_4_or_pipe(self):
         p = pipe.make_pipe()