(stream_in, chunk_size=4096)
| 95 | |
| 96 | |
| 97 | def _read_all_bytes(stream_in, chunk_size=4096): |
| 98 | all_data = b"" |
| 99 | while True: |
| 100 | data = stream_in.read(chunk_size) |
| 101 | all_data += data |
| 102 | if len(data) < chunk_size: |
| 103 | break |
| 104 | return all_data |
| 105 | |
| 106 | |
| 107 | def pickle_echo(stream_in=None, stream_out=None, protocol=None): |
no outgoing calls
no test coverage detected
searching dependent graphs…