aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHenauxg <19689618+Henauxg@users.noreply.github.com>2022-11-18 16:00:12 +0100
committerHenauxg <19689618+Henauxg@users.noreply.github.com>2022-11-18 16:00:12 +0100
commitffc259f2e6d909ee74b4fddc2705229777ea3cdd (patch)
tree865f2a2e0f7491c13ea6f913a8cb841fc4a5cb27
parent354c7e0bc53f8e67dcfbbd88d849a4284a37ff8e (diff)
[examples&readme] Update examples and code samples
-rw-r--r--README.md19
-rw-r--r--examples/breakout/server.rs2
-rw-r--r--examples/chat/server.rs2
3 files changed, 12 insertions, 11 deletions
diff --git a/README.md b/README.md
index 349bdd3..909d6cc 100644
--- a/README.md
+++ b/README.md
@@ -146,7 +146,7 @@ fn handle_server_messages(
```rust
fn start_listening(mut server: ResMut<Server>) {
server
- .start(
+ .start_endpoint(
ServerConfigurationData::new("127.0.0.1".to_string(), 6000, "0.0.0.0".to_string()),
CertificateRetrievalMode::GenerateSelfSigned,
)
@@ -161,22 +161,23 @@ fn handle_client_messages(
mut server: ResMut<Server>,
/*...*/
) {
- while let Ok(Some((message, client_id))) = server.receive_message::<ClientMessage>() {
+ let mut endpoint = server.endpoint_mut();
+ while let Ok(Some((message, client_id))) = endpoint.receive_message::<ClientMessage>() {
match message {
// Match on your own message types ...
ClientMessage::Join { username} => {
// Send a messsage to 1 client
- server.send_message(client_id, ServerMessage::InitClient {/*...*/}).unwrap();
+ endpoint.send_message(client_id, ServerMessage::InitClient {/*...*/}).unwrap();
/*...*/
}
ClientMessage::Disconnect { } => {
// Disconnect a client
- server.disconnect_client(client_id);
+ endpoint.disconnect_client(client_id);
/*...*/
}
ClientMessage::ChatMessage { message } => {
// Send a message to a group of clients
- server.send_group_message(
+ endpoint.send_group_message(
client_group, // Iterator of ClientId
ServerMessage::ChatMessage {/*...*/}
)
@@ -188,7 +189,7 @@ fn handle_client_messages(
}
```
-You can also use `server.broadcast_message`, which will send a message to all connected clients. "Connected" here means connected to the server plugin, which happens before your own app handshakes/verifications if you have any. Use `send_group_message` if you want to control the recipients.
+You can also use `endpoint.broadcast_message`, which will send a message to all connected clients. "Connected" here means connected to the server plugin, which happens before your own app handshakes/verifications if you have any. Use `send_group_message` if you want to control the recipients.
## Certificates and server authentication
@@ -224,14 +225,14 @@ On the server:
```rust
// To generate a new self-signed certificate on each startup
- server.start(/*...*/, CertificateRetrievalMode::GenerateSelfSigned);
+ server.start_endpoint(/*...*/, CertificateRetrievalMode::GenerateSelfSigned);
// To load a pre-existing one from files
- server.start(/*...*/, CertificateRetrievalMode::LoadFromFile {
+ server.start_endpoint(/*...*/, CertificateRetrievalMode::LoadFromFile {
cert_file: "./certificates.pem".into(),
key_file: "./privkey.pem".into(),
});
// To load one from files, or to generate a new self-signed one if the files do not exist.
- server.start(/*...*/, CertificateRetrievalMode::LoadFromFileOrGenerateSelfSigned {
+ server.start_endpoint(/*...*/, CertificateRetrievalMode::LoadFromFileOrGenerateSelfSigned {
cert_file: "./certificates.pem".into(),
key_file: "./privkey.pem".into(),
save_on_disk: true, // To persist on disk if generated
diff --git a/examples/breakout/server.rs b/examples/breakout/server.rs
index 62d1303..a06bb86 100644
--- a/examples/breakout/server.rs
+++ b/examples/breakout/server.rs
@@ -80,7 +80,7 @@ struct WallBundle {
pub(crate) fn start_listening(mut server: ResMut<Server>) {
server
- .open_endpoint(
+ .start_endpoint(
ServerConfigurationData::new(
SERVER_HOST.to_string(),
SERVER_PORT,
diff --git a/examples/chat/server.rs b/examples/chat/server.rs
index 7fa4f23..4a3481a 100644
--- a/examples/chat/server.rs
+++ b/examples/chat/server.rs
@@ -114,7 +114,7 @@ fn handle_disconnect(endpoint: &mut Endpoint, users: &mut ResMut<Users>, client_
fn start_listening(mut server: ResMut<Server>) {
server
- .open_endpoint(
+ .start_endpoint(
ServerConfigurationData::new("127.0.0.1".to_string(), 6000, "0.0.0.0".to_string()),
CertificateRetrievalMode::GenerateSelfSigned,
)