| 291 | } |
| 292 | |
| 293 | void DataSourceRuntimeHost::flushPending() { |
| 294 | source_write_host_.flushPending(); |
| 295 | for (auto& [binding_id, binding] : parser_bindings_) { |
| 296 | if (binding.write_host != nullptr) { |
| 297 | binding.write_host->flushPending(); |
| 298 | } |
| 299 | } |
| 300 | } |
| 301 | void DataSourceRuntimeHost::requestStop(std::string_view reason) { |
| 302 | last_error_.assign(reason.data(), reason.size()); |
| 303 | stop_requested_.store(true); |
no outgoing calls