| 707 | } |
| 708 | |
| 709 | inline void Process(const TString& s) { |
| 710 | Y_ASSERT(State_ != HeadersSent); |
| 711 | |
| 712 | if (State_ == Begin) { |
| 713 | FirstLine_ = s; |
| 714 | ParseHttpVersion(); |
| 715 | State_ = FirstLineSent; |
| 716 | } else { |
| 717 | if (s.empty()) { |
| 718 | BuildOutputStream(); |
| 719 | WriteCached(); |
| 720 | State_ = HeadersSent; |
| 721 | } else { |
| 722 | AddHeader(THttpInputHeader(s)); |
| 723 | } |
| 724 | } |
| 725 | } |
| 726 | |
| 727 | inline void WriteCachedImpl(IOutputStream* s) const { |
| 728 | s->Write(FirstLine_.data(), FirstLine_.size()); |
nothing calls this directly
no test coverage detected