| 101 | } |
| 102 | |
| 103 | void ServeRequest(const IRequestRef& req) { |
| 104 | TData res(R_.data(), R_.data() + R_.size()); |
| 105 | if (req->Data().StartsWith("delay ")) { |
| 106 | TStringBuf delay = req->Data(); |
| 107 | delay.Skip(6); |
| 108 | TInstant respTime = TDuration::MilliSeconds(FromString<size_t>(delay.Before('\n'))).ToDeadLine(); |
| 109 | D_.SendResponseAt(respTime, req, res); |
| 110 | } else { |
| 111 | req->SendReply(res); |
| 112 | } |
| 113 | } |
| 114 | |
| 115 | private: |
| 116 | TString R_; |
nothing calls this directly
no test coverage detected