| 273 | } |
| 274 | |
| 275 | Future<Void> BufferedConnection::onBytesAvailable(int count) { |
| 276 | return doOnBytesAvailable(self, count); |
| 277 | } |
| 278 | |
| 279 | ACTOR Future<Void> doRead(BufferedConnection* bc, BufferedConnectionData* self, uint8_t* buf, int count) { |
| 280 | wait(bc->onBytesAvailable(count)); |
no outgoing calls
no test coverage detected