| 241 | } |
| 242 | |
| 243 | void HttpDataStream::Interrupt() { |
| 244 | std::unique_lock<std::mutex> lock(this->stateMutex); |
| 245 | |
| 246 | auto reader = this->reader; |
| 247 | auto downloadThread = this->downloadThread; |
| 248 | |
| 249 | if (reader) { |
| 250 | reader->Interrupt(); |
| 251 | } |
| 252 | |
| 253 | if (downloadThread) { |
| 254 | this->interrupted = true; |
| 255 | } |
| 256 | } |
| 257 | |
| 258 | bool HttpDataStream::CanPrefetch() { |
| 259 | return true; |
no outgoing calls
no test coverage detected