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