From: Walter Dörwald <walter@livinglogic.de>
Date: Mon, 6 Mar 2006 22:39:12 +0000 (+0000)
Subject: If size is specified, try to read at least size characters.
X-Git-Tag: v2.5a0~351
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=ca199432c23fa00ab3702e64a136c377950e5068;p=python

If size is specified, try to read at least size characters.
This is a alternative version of patch #1379332.
---

diff --git a/Lib/codecs.py b/Lib/codecs.py
index 932f01bec7..6895a228fe 100644
--- a/Lib/codecs.py
+++ b/Lib/codecs.py
@@ -274,7 +274,10 @@ class StreamReader(Codec):
         while True:
             # can the request can be satisfied from the character buffer?
             if chars < 0:
-                if self.charbuffer:
+                if size < 0:
+                    if self.charbuffer:
+                        break
+                elif len(self.charbuffer) >= size:
                     break
             else:
                 if len(self.charbuffer) >= chars:
diff --git a/Lib/test/test_codecs.py b/Lib/test/test_codecs.py
index ded5d1917a..3944d65452 100644
--- a/Lib/test/test_codecs.py
+++ b/Lib/test/test_codecs.py
@@ -46,19 +46,23 @@ class ReadTest(unittest.TestCase):
             stream = StringIO.StringIO(input.encode(self.encoding))
             return codecs.getreader(self.encoding)(stream)
 
-        def readalllines(input, keepends=True):
+        def readalllines(input, keepends=True, size=None):
             reader = getreader(input)
             lines = []
             while True:
-                line = reader.readline(keepends=keepends)
+                line = reader.readline(size=size, keepends=keepends)
                 if not line:
                     break
                 lines.append(line)
-            return "".join(lines)
+            return "|".join(lines)
 
         s = u"foo\nbar\r\nbaz\rspam\u2028eggs"
-        self.assertEqual(readalllines(s, True), s)
-        self.assertEqual(readalllines(s, False), u"foobarbazspameggs")
+        sexpected = u"foo\n|bar\r\n|baz\r|spam\u2028|eggs"
+        sexpectednoends = u"foo|bar|baz|spam|eggs"
+        self.assertEqual(readalllines(s, True), sexpected)
+        self.assertEqual(readalllines(s, False), sexpectednoends)
+        self.assertEqual(readalllines(s, True, 10), sexpected)
+        self.assertEqual(readalllines(s, False, 10), sexpectednoends)
 
         # Test long lines (multiple calls to read() in readline())
         vw = []