@@ -567,7 +567,9 @@ def recv_into(self, buffer: bytearray, nbytes: int = 0, flags: int = 0) -> int:
567
567
# _readline
568
568
if len (self ._buffer ) > 0 :
569
569
bytes_to_read = min (num_to_read , len (self ._buffer ))
570
- buffer [num_read : num_read + bytes_to_read ] = self ._buffer [:bytes_to_read ]
570
+ buffer [num_read : num_read + bytes_to_read ] = self ._buffer [
571
+ :bytes_to_read
572
+ ]
571
573
num_read += bytes_to_read
572
574
num_to_read -= bytes_to_read
573
575
self ._buffer = self ._buffer [bytes_to_read :]
@@ -579,9 +581,13 @@ def recv_into(self, buffer: bytearray, nbytes: int = 0, flags: int = 0) -> int:
579
581
last_read_time = time .monotonic ()
580
582
bytes_to_read = min (num_to_read , num_avail )
581
583
if self ._sock_type == SOCK_STREAM :
582
- bytes_read = _the_interface .socket_read (self ._socknum , bytes_to_read )[1 ]
584
+ bytes_read = _the_interface .socket_read (
585
+ self ._socknum , bytes_to_read
586
+ )[1 ]
583
587
else :
584
- bytes_read = _the_interface .read_udp (self ._socknum , bytes_to_read )[1 ]
588
+ bytes_read = _the_interface .read_udp (self ._socknum , bytes_to_read )[
589
+ 1
590
+ ]
585
591
buffer [num_read : num_read + len (bytes_read )] = bytes_read
586
592
num_read += len (bytes_read )
587
593
num_to_read -= len (bytes_read )
0 commit comments