| 576 | } |
| 577 | |
| 578 | inline ~TClient() { |
| 579 | Reqs.Enqueue(nullptr); |
| 580 | Thr->Join(); |
| 581 | } |
| 582 | |
| 583 | inline THandleRef Schedule(const TNehMessage& msg, IOnRecv* fallback, TServiceStatRef& ss) { |
| 584 | TSimpleHandleRef ret(new TSimpleHandle(fallback, msg, !ss ? nullptr : new TStatCollector(ss))); |