| 126 | } |
| 127 | |
| 128 | void processResponseEvent(bbg::Event &event, Ticks &ticks, const bool verbose) { |
| 129 | bbg::MessageIterator msgIter(event); |
| 130 | while (msgIter.next()) { |
| 131 | bbg::Message msg = msgIter.message(); |
| 132 | if (msg.hasElement(RESPONSE_ERROR)) { |
| 133 | Rcpp::Rcerr << "REQUEST FAILED: " << msg.getElement(RESPONSE_ERROR) << std::endl; |
| 134 | continue; |
| 135 | } |
| 136 | processMessage(msg, ticks, verbose); |
| 137 | } |
| 138 | } |
| 139 | |
| 140 | // [[Rcpp::export]] |
| 141 | Rcpp::DataFrame getTicks_Impl(SEXP con, |
no test coverage detected