| 874 | } |
| 875 | |
| 876 | int Write(const char* data, size_t dlen, size_t* written) override { |
| 877 | if (Y_UNLIKELY(!Cont_)) { |
| 878 | return -1; |
| 879 | } |
| 880 | |
| 881 | while (true) { |
| 882 | auto done = NCoro::WriteI(Cont_, S_, data, dlen); |
| 883 | if (done.Status() != EAGAIN) { |
| 884 | *written = done.Checked(); |
| 885 | return 1; |
| 886 | } |
| 887 | } |
| 888 | } |
| 889 | |
| 890 | int Read(char* data, size_t dlen, size_t* readbytes) override { |
| 891 | if (Y_UNLIKELY(!Cont_)) { |
no test coverage detected