| 2253 | } |
| 2254 | |
| 2255 | std::shared_ptr<Stream> StreamingDestination::CreateNewOutgoingStream (std::shared_ptr<const i2p::data::LeaseSet> remote, int port) |
| 2256 | { |
| 2257 | auto s = std::make_shared<Stream> (m_Owner->GetService (), *this, remote, port); |
| 2258 | std::unique_lock<std::mutex> l(m_StreamsMutex); |
| 2259 | m_Streams.emplace (s->GetRecvStreamID (), s); |
| 2260 | return s; |
| 2261 | } |
| 2262 | |
| 2263 | void StreamingDestination::SendPing (std::shared_ptr<const i2p::data::LeaseSet> remote) |
| 2264 | { |
no test coverage detected