Blacken Paramiko on 2.4

1 files changed, 36 insertions, 30 deletions

diff --git a/paramiko/file.py b/paramiko/file.py
index df9cdac7..62686b53 100644
--- a/paramiko/file.py
+++ b/paramiko/file.py
@@ -16,14 +16,18 @@
 # along with Paramiko; if not, write to the Free Software Foundation, Inc.,
 # 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA.
 from paramiko.common import (
-    linefeed_byte_value, crlf, cr_byte, linefeed_byte, cr_byte_value,
+    linefeed_byte_value,
+    crlf,
+    cr_byte,
+    linefeed_byte,
+    cr_byte_value,
 )
 from paramiko.py3compat import BytesIO, PY2, u, bytes_types, text_type
 
 from paramiko.util import ClosingContextManager
 
 
-class BufferedFile (ClosingContextManager):
+class BufferedFile(ClosingContextManager):
     """
     Reusable base class to implement Python-style file buffering around a
     simpler stream.
@@ -70,7 +74,7 @@ class BufferedFile (ClosingContextManager):
         :raises: ``ValueError`` -- if the file is closed.
         """
         if self._closed:
-            raise ValueError('I/O operation on closed file')
+            raise ValueError("I/O operation on closed file")
         return self
 
     def close(self):
@@ -90,6 +94,7 @@ class BufferedFile (ClosingContextManager):
         return
 
     if PY2:
+
         def next(self):
             """
             Returns the next line from the input, or raises
@@ -104,7 +109,9 @@ class BufferedFile (ClosingContextManager):
             if not line:
                 raise StopIteration
             return line
+
     else:
+
         def __next__(self):
             """
             Returns the next line from the input, or raises ``StopIteration``
@@ -180,9 +187,9 @@ class BufferedFile (ClosingContextManager):
             encountered immediately
         """
         if self._closed:
-            raise IOError('File is closed')
+            raise IOError("File is closed")
         if not (self._flags & self.FLAG_READ):
-            raise IOError('File is not open for reading')
+            raise IOError("File is not open for reading")
         if (size is None) or (size < 0):
             # go for broke
             result = self._rbuffer
@@ -245,16 +252,16 @@ class BufferedFile (ClosingContextManager):
         """
         # it's almost silly how complex this function is.
         if self._closed:
-            raise IOError('File is closed')
+            raise IOError("File is closed")
         if not (self._flags & self.FLAG_READ):
-            raise IOError('File not open for reading')
+            raise IOError("File not open for reading")
         line = self._rbuffer
         truncated = False
         while True:
             if (
-                self._at_trailing_cr and
-                self._flags & self.FLAG_UNIVERSAL_NEWLINE and
-                len(line) > 0
+                self._at_trailing_cr
+                and self._flags & self.FLAG_UNIVERSAL_NEWLINE
+                and len(line) > 0
             ):
                 # edge case: the newline may be '\r\n' and we may have read
                 # only the first '\r' last time.
@@ -277,10 +284,10 @@ class BufferedFile (ClosingContextManager):
             else:
                 n = self._bufsize
             if (
-                linefeed_byte in line or
-                (
-                    self._flags & self.FLAG_UNIVERSAL_NEWLINE and
-                    cr_byte in line
+                linefeed_byte in line
+                or (
+                    self._flags & self.FLAG_UNIVERSAL_NEWLINE
+                    and cr_byte in line
                 )
             ):
                 break
@@ -306,9 +313,9 @@ class BufferedFile (ClosingContextManager):
             return line if self._flags & self.FLAG_BINARY else u(line)
         xpos = pos + 1
         if (
-            line[pos] == cr_byte_value and
-            xpos < len(line) and
-            line[xpos] == linefeed_byte_value
+            line[pos] == cr_byte_value
+            and xpos < len(line)
+            and line[xpos] == linefeed_byte_value
         ):
             xpos += 1
         # if the string was truncated, _rbuffer needs to have the string after
@@ -370,7 +377,7 @@ class BufferedFile (ClosingContextManager):
 
         :raises: ``IOError`` -- if the file doesn't support random access.
         """
-        raise IOError('File does not support seeking.')
+        raise IOError("File does not support seeking.")
 
     def tell(self):
         """
@@ -393,11 +400,11 @@ class BufferedFile (ClosingContextManager):
         """
         if isinstance(data, text_type):
             # Accept text and encode as utf-8 for compatibility only.
-            data = data.encode('utf-8')
+            data = data.encode("utf-8")
         if self._closed:
-            raise IOError('File is closed')
+            raise IOError("File is closed")
         if not (self._flags & self.FLAG_WRITE):
-            raise IOError('File not open for writing')
+            raise IOError("File not open for writing")
         if not (self._flags & self.FLAG_BUFFERED):
             self._write_all(data)
             return
@@ -457,7 +464,7 @@ class BufferedFile (ClosingContextManager):
         (subclass override)
         Write data into the stream.
         """
-        raise IOError('write not implemented')
+        raise IOError("write not implemented")
 
     def _get_size(self):
         """
@@ -472,7 +479,7 @@ class BufferedFile (ClosingContextManager):
 
     # ...internals...
 
-    def _set_mode(self, mode='r', bufsize=-1):
+    def _set_mode(self, mode="r", bufsize=-1):
         """
         Subclasses call this method to initialize the BufferedFile.
         """
@@ -495,17 +502,17 @@ class BufferedFile (ClosingContextManager):
             # unbuffered
             self._flags &= ~(self.FLAG_BUFFERED | self.FLAG_LINE_BUFFERED)
 
-        if ('r' in mode) or ('+' in mode):
+        if ("r" in mode) or ("+" in mode):
             self._flags |= self.FLAG_READ
-        if ('w' in mode) or ('+' in mode):
+        if ("w" in mode) or ("+" in mode):
             self._flags |= self.FLAG_WRITE
-        if 'a' in mode:
+        if "a" in mode:
             self._flags |= self.FLAG_WRITE | self.FLAG_APPEND
             self._size = self._get_size()
             self._pos = self._realpos = self._size
-        if 'b' in mode:
+        if "b" in mode:
             self._flags |= self.FLAG_BINARY
-        if 'U' in mode:
+        if "U" in mode:
             self._flags |= self.FLAG_UNIVERSAL_NEWLINE
             # built-in file objects have this attribute to store which kinds of
             # line terminations they've seen:
@@ -535,8 +542,7 @@ class BufferedFile (ClosingContextManager):
         if self.newlines is None:
             self.newlines = newline
         elif (
-            self.newlines != newline and
-            isinstance(self.newlines, bytes_types)
+            self.newlines != newline and isinstance(self.newlines, bytes_types)
         ):
             self.newlines = (self.newlines, newline)
         elif newline not in self.newlines: