| 70 | } |
| 71 | |
| 72 | void connect(const std::shared_ptr<dap::Reader>& r, |
| 73 | const std::shared_ptr<dap::Writer>& w) override { |
| 74 | if (isBound.exchange(true)) { |
| 75 | handlers.error("Session is already bound!"); |
| 76 | return; |
| 77 | } |
| 78 | |
| 79 | reader = dap::ContentReader(r); |
| 80 | writer = dap::ContentWriter(w); |
| 81 | } |
| 82 | |
| 83 | void startProcessingMessages() override { |
| 84 | recvThread = std::thread([this] { |
nothing calls this directly
no test coverage detected