mirror of
https://github.com/msgpack/msgpack-python.git
synced 2025-10-20 04:13:16 +00:00
Cleaner read_bytes and a test case
No longer reads via buffer for unbuffered bytes
This commit is contained in:
parent
ffec10dff3
commit
e7c51d9089
2 changed files with 21 additions and 7 deletions
|
@ -458,13 +458,11 @@ cdef class Unpacker(object):
|
|||
def read_bytes(self, Py_ssize_t nbytes):
|
||||
"""read a specified number of raw bytes from the stream"""
|
||||
cdef size_t nread
|
||||
ret = ''
|
||||
while len(ret) < nbytes and self.file_like is not None:
|
||||
if self.buf_head == self.buf_tail:
|
||||
self.fill_buffer()
|
||||
nread = min(self.buf_tail - self.buf_head, nbytes - len(ret))
|
||||
ret += PyBytes_FromStringAndSize(self.buf + self.buf_head, nread)
|
||||
self.buf_head += nread
|
||||
nread = min(self.buf_tail - self.buf_head, nbytes)
|
||||
ret = PyBytes_FromStringAndSize(self.buf + self.buf_head, nread)
|
||||
self.buf_head += nread
|
||||
if len(ret) < nbytes and self.file_like is not None:
|
||||
ret += self.file_like.read(nbytes - len(ret))
|
||||
return ret
|
||||
|
||||
def __iter__(self):
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue