| 261 | explicit RSocketStream(RSockFD&& fd) : rfd(std::move(fd)) {} |
| 262 | |
| 263 | uint64_t timeout() const override { return m_timeout; } |
| 264 | void timeout(uint64_t tm) override { m_timeout = tm; } |
| 265 | Object* get_underlay_object(uint64_t) override { |
| 266 | return rfd.get_underlay_object(0); |
no outgoing calls
no test coverage detected