| 237 | } |
| 238 | |
| 239 | bool ISocketStream::skip_read(size_t count) { |
| 240 | static char buf[1024]; |
| 241 | return DOIO_LOOP(read(buf, std::min(count, sizeof(buf))), BufStep(count)); |
| 242 | } |
| 243 | |
| 244 | ssize_t ISocketStream::recv_at_least(void* buf, size_t count, size_t least, int flags) { |
| 245 | return DOIO_LOOP_LAMBDA(recv(buf, count, flags), { |