(pl: integration_pb::UplinkEvent)
| 308 | } |
| 309 | |
| 310 | async fn uplink_event(pl: integration_pb::UplinkEvent) { |
| 311 | let integration = INTEGRATION.read().await; |
| 312 | if let Err(e) = integration.as_ref().unwrap().uplink_event(&pl).await { |
| 313 | error!(error = %e, "Uplink event error"); |
| 314 | } |
| 315 | } |
| 316 | |
| 317 | async fn join_event(pl: integration_pb::JoinEvent) { |
| 318 | let integration = INTEGRATION.read().await; |
no test coverage detected