Receive bytes data into a writeable bytes-like object. Return the number of bytes read.
(self, buf, offset=0)
| 219 | return buf.getvalue() |
| 220 | |
| 221 | def recv_bytes_into(self, buf, offset=0): |
| 222 | """ |
| 223 | Receive bytes data into a writeable bytes-like object. |
| 224 | Return the number of bytes read. |
| 225 | """ |
| 226 | self._check_closed() |
| 227 | self._check_readable() |
| 228 | with memoryview(buf) as m: |
| 229 | # Get bytesize of arbitrary buffer |
| 230 | itemsize = m.itemsize |
| 231 | bytesize = itemsize * len(m) |
| 232 | if offset < 0: |
| 233 | raise ValueError("negative offset") |
| 234 | elif offset > bytesize: |
| 235 | raise ValueError("offset too large") |
| 236 | result = self._recv_bytes() |
| 237 | size = result.tell() |
| 238 | if bytesize < offset + size: |
| 239 | raise BufferTooShort(result.getvalue()) |
| 240 | # Message can fit in dest |
| 241 | result.seek(0) |
| 242 | result.readinto(m[offset // itemsize : |
| 243 | (offset + size) // itemsize]) |
| 244 | return size |
| 245 | |
| 246 | def recv(self): |
| 247 | """Receive a (picklable) object""" |