| 668 | class TProtocol: public IProtocol { |
| 669 | public: |
| 670 | IRequesterRef CreateRequester(IOnRequest* cb, const TParsedLocation& loc) override { |
| 671 | return new TRequester(cb, loc.GetPort()); |
| 672 | } |
| 673 | |
| 674 | THandleRef ScheduleRequest(const TMessage& msg, IOnRecv* fallback, TServiceStatRef& ss) override { |
| 675 | TNotifyHandleRef ret(new TUdpHandle(fallback, msg, !ss ? nullptr : new TStatCollector(ss))); |