diff options
Diffstat (limited to 'test_utils')
| -rw-r--r-- | test_utils/src/relay.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test_utils/src/relay.rs b/test_utils/src/relay.rs index 87eb081..4ef34e6 100644 --- a/test_utils/src/relay.rs +++ b/test_utils/src/relay.rs | |||
| @@ -105,12 +105,12 @@ impl<'a> Relay<'a> { | |||
| 105 | // remove the disconnected client from the clients map: | 105 | // remove the disconnected client from the clients map: |
| 106 | println!("{} disconnected", self.port); | 106 | println!("{} disconnected", self.port); |
| 107 | self.clients.remove(&client_id); | 107 | self.clients.remove(&client_id); |
| 108 | break; | 108 | // break; |
| 109 | } | 109 | } |
| 110 | simple_websockets::Event::Message(client_id, message) => { | 110 | simple_websockets::Event::Message(client_id, message) => { |
| 111 | println!( | 111 | println!( |
| 112 | "Received a message from client #{}: {:?}", | 112 | "{} Received a message from client #{}: {:?}", |
| 113 | client_id, message | 113 | self.port, client_id, message |
| 114 | ); | 114 | ); |
| 115 | if let simple_websockets::Message::Text(s) = message.clone() { | 115 | if let simple_websockets::Message::Text(s) = message.clone() { |
| 116 | if s.eq("shut me down") { | 116 | if s.eq("shut me down") { |
| @@ -139,7 +139,7 @@ impl<'a> Relay<'a> { | |||
| 139 | } | 139 | } |
| 140 | if is_nclose(&message) { | 140 | if is_nclose(&message) { |
| 141 | println!("{} recieved nostr close", self.port); | 141 | println!("{} recieved nostr close", self.port); |
| 142 | break; | 142 | // break; |
| 143 | } | 143 | } |
| 144 | } | 144 | } |
| 145 | } | 145 | } |