(&self)
| 235 | |
| 236 | impl CallbackServerState { |
| 237 | fn take_sender(&self) -> Option<oneshot::Sender<String>> { |
| 238 | self.tx |
| 239 | .lock() |
| 240 | .unwrap_or_else(std::sync::PoisonError::into_inner) |
| 241 | .take() |
| 242 | } |
| 243 | } |
| 244 | |
| 245 | type CallbackResponse = Response<Full<Bytes>>; |
no outgoing calls
no test coverage detected