| 68 | // Protocol implementation |
| 69 | void onReceived(const void* buffer, size_t size) override { receive(buffer, size); } |
| 70 | size_t onSend(const void* data, size_t size) override { return SendAsync(data, size) ? size : 0; } |
| 71 | |
| 72 | private: |
| 73 | std::atomic<bool> _stop{false}; |
nothing calls this directly
no outgoing calls
no test coverage detected