diff options
Diffstat (limited to 'src/server.rs')
-rw-r--r-- | src/server.rs | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/src/server.rs b/src/server.rs index f8ec3f6..f2684e3 100644 --- a/src/server.rs +++ b/src/server.rs @@ -24,7 +24,7 @@ use crate::{ }, }; -use self::certificate::{CertificateRetrievalMode, CertificateRetrievedEvent, ServerCertificate}; +use self::certificate::{CertificateRetrievalMode, ServerCertificate}; pub mod certificate; @@ -90,7 +90,6 @@ pub struct ClientPayload { pub(crate) enum InternalAsyncMessage { ClientConnected(ClientConnection), ClientLostConnection(ClientId), - CertificateRetrieved(CertificateRetrievedEvent), } #[derive(Debug, Clone)] @@ -241,7 +240,7 @@ impl Server { } /// Run the server with the given [ServerConfigurationData] and [CertificateRetrievalMode] - pub fn open_endpoint( + pub fn start_endpoint( &mut self, config: ServerConfigurationData, cert_mode: CertificateRetrievalMode, @@ -289,7 +288,7 @@ impl Server { Ok(server_cert) } - pub fn close_endpoint(&mut self) { + pub fn stop_endpoint(&mut self) { self.endpoint = None; } @@ -484,7 +483,6 @@ fn update_sync_server( mut server: ResMut<Server>, mut connection_events: EventWriter<ConnectionEvent>, mut connection_lost_events: EventWriter<ConnectionLostEvent>, - mut certificate_retrieved_events: EventWriter<CertificateRetrievedEvent>, ) { if let Some(endpoint) = server.get_endpoint_mut() { while let Ok(message) = endpoint.internal_receiver.try_recv() { @@ -502,9 +500,6 @@ fn update_sync_server( endpoint.clients.remove(&client_id); connection_lost_events.send(ConnectionLostEvent { id: client_id }); } - InternalAsyncMessage::CertificateRetrieved(event) => { - certificate_retrieved_events.send(event) - } } } } @@ -522,7 +517,6 @@ impl Plugin for QuinnetServerPlugin { fn build(&self, app: &mut App) { app.add_event::<ConnectionEvent>() .add_event::<ConnectionLostEvent>() - .add_event::<CertificateRetrievedEvent>() .add_startup_system_to_stage(StartupStage::PreStartup, create_server) .add_system_to_stage(CoreStage::PreUpdate, update_sync_server); |