| 293 | match self.clock_state_handle.tx.send(source_params.clone()) { |
| 294 | Ok(()) => (), |
| 295 | Err(SendError::Disrupted(source_params)) => { |
| 296 | // don't handle_disruption. It will be handled on the next call of tokio::select |
| 297 | debug!( |
| 298 | ?source_params, |
| 299 | "Trying to send a value when there was a disruption event. Dropping." |
| 300 | ); |
| 301 | } |
| 302 | Err(SendError::BufferClosed(e)) => { |
| 303 | error!( |
nothing calls this directly
no outgoing calls
no test coverage detected