- if sock_timeout:
- ready_to_read = select.select([sock], [], [], sock_timeout)[0]
- if not ready_to_read:
- continue
- received = recv_chunk(reader)
- buf += received.decode('utf-8')
- if received:
- heartbeat_timer.reset()
- except (ChunkDecodeError, EndOfStream):
- yield Hangup
- break
+ ready_to_read = select.select([sock], [], [], sock_timeout)[0]
+ if not ready_to_read:
+ continue
+ data = sock.read()