| 213 | } |
| 214 | |
| 215 | void peekerWorker(shared_ptr<TTransport> tt, bool expectedResult) { |
| 216 | uint8_t buf[400]; |
| 217 | try { |
| 218 | tt->read(buf, 1); |
| 219 | BOOST_CHECK_EQUAL(expectedResult, tt->peek()); |
| 220 | } catch (const TTransportException& tx) { |
| 221 | BOOST_CHECK_EQUAL(TTransportException::TIMED_OUT, tx.getType()); |
| 222 | } |
| 223 | } |
| 224 | |
| 225 | void peekerWorkerInterrupt(shared_ptr<TTransport> tt) { |
| 226 | uint8_t buf[400]; |