| 243 | } |
| 244 | |
| 245 | foreach (const std::string& record, decode.get()) { |
| 246 | Result<T> t = deserialize(record); |
| 247 | |
| 248 | if (!waiters.empty()) { |
| 249 | waiters.front()->set(std::move(t)); |
| 250 | waiters.pop(); |
| 251 | } else { |
| 252 | records.push(std::move(t)); |
| 253 | } |
| 254 | } |
| 255 | |
| 256 | consume(); |
| 257 | } |
nothing calls this directly
no test coverage detected