diff options
Diffstat (limited to 'examples/chat')
| -rw-r--r-- | examples/chat/client.rs | 8 | ||||
| -rw-r--r-- | examples/chat/server.rs | 16 |
2 files changed, 12 insertions, 12 deletions
diff --git a/examples/chat/client.rs b/examples/chat/client.rs index ce71226..d9908ae 100644 --- a/examples/chat/client.rs +++ b/examples/chat/client.rs @@ -47,7 +47,10 @@ pub fn on_app_exit(app_exit_events: EventReader<AppExit>, client: Res<Client>) { } fn handle_server_messages(mut users: ResMut<Users>, mut client: ResMut<Client>) { - while let Ok(Some(message)) = client.connection_mut().receive_message::<ServerMessage>() { + while let Some(message) = client + .connection_mut() + .try_receive_message::<ServerMessage>() + { match message { ServerMessage::ClientConnected { client_id, @@ -94,8 +97,7 @@ fn handle_terminal_messages( } else { client .connection() - .send_message(ClientMessage::ChatMessage { message: message }) - .expect("Failed to send chat message"); + .try_send_message(ClientMessage::ChatMessage { message: message }); } } } diff --git a/examples/chat/server.rs b/examples/chat/server.rs index 4a3481a..007e038 100644 --- a/examples/chat/server.rs +++ b/examples/chat/server.rs @@ -64,15 +64,13 @@ fn handle_client_messages(mut server: ResMut<Server>, mut users: ResMut<Users>) users.names.get(&client_id), message ); - endpoint - .send_group_message( - users.names.keys().into_iter(), - ServerMessage::ChatMessage { - client_id: client_id, - message: message, - }, - ) - .unwrap(); + endpoint.try_send_group_message( + users.names.keys().into_iter(), + ServerMessage::ChatMessage { + client_id: client_id, + message: message, + }, + ); } } } |