(&self, pl: &integration_pb::JoinEvent)
| 391 | } |
| 392 | |
| 393 | async fn join_event(&self, pl: &integration_pb::JoinEvent) -> Result<()> { |
| 394 | JOIN_EVENTS.write().await.push(pl.clone()); |
| 395 | Ok(()) |
| 396 | } |
| 397 | |
| 398 | async fn ack_event(&self, pl: &integration_pb::AckEvent) -> Result<()> { |
| 399 | ACK_EVENTS.write().await.push(pl.clone()); |