| 2320 | } |
| 2321 | |
| 2322 | void StreamingDestination::SetAcceptor (const Acceptor& acceptor) |
| 2323 | { |
| 2324 | m_Acceptor = acceptor; // we must set it immediately for IsAcceptorSet |
| 2325 | auto s = shared_from_this (); |
| 2326 | boost::asio::post (m_Owner->GetService (), [s](void) |
| 2327 | { |
| 2328 | // take care about incoming queue |
| 2329 | for (auto& it: s->m_PendingIncomingStreams) |
| 2330 | if (it->GetStatus () == eStreamStatusOpen) // still open? |
| 2331 | s->m_Acceptor (it); |
| 2332 | s->m_PendingIncomingStreams.clear (); |
| 2333 | s->m_PendingIncomingTimer.cancel (); |
| 2334 | }); |
| 2335 | } |
| 2336 | |
| 2337 | void StreamingDestination::ResetAcceptor () |
| 2338 | { |
no test coverage detected