| 72 | } |
| 73 | |
| 74 | void SendBufferQueue::CleanUp () |
| 75 | { |
| 76 | if (!m_Buffers.empty ()) |
| 77 | { |
| 78 | for (auto& it: m_Buffers) |
| 79 | it->Cancel (); |
| 80 | m_Buffers.clear (); |
| 81 | m_Size = 0; |
| 82 | } |
| 83 | } |
| 84 | |
| 85 | Stream::Stream (boost::asio::io_context& service, StreamingDestination& local, |
| 86 | std::shared_ptr<const i2p::data::LeaseSet> remote, int port): m_Service (service), |
no test coverage detected