diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-07-16 11:01:44 +0100 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-07-16 11:01:44 +0100 |
| commit | 7704178c618f8ac455cd6b0582edb511a9e644c3 (patch) | |
| tree | 775e425f0af2543eb12e4a4b1d4feb022611368f /test_utils/src/relay.rs | |
| parent | 8cea674f58e806c22d2887cff5e6f76bc4dba0db (diff) | |
| parent | ac53bca7e315848864ff9e51703720b5b466bc42 (diff) | |
Merge branch 'upgrade-dependancies'
Diffstat (limited to 'test_utils/src/relay.rs')
| -rw-r--r-- | test_utils/src/relay.rs | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/test_utils/src/relay.rs b/test_utils/src/relay.rs index e820651..b14f532 100644 --- a/test_utils/src/relay.rs +++ b/test_utils/src/relay.rs | |||
| @@ -161,9 +161,11 @@ impl<'a> Relay<'a> { | |||
| 161 | if let Some(listner) = self.req_listener { | 161 | if let Some(listner) = self.req_listener { |
| 162 | listner(self, client_id, subscription_id, vec![filter.clone()])?; | 162 | listner(self, client_id, subscription_id, vec![filter.clone()])?; |
| 163 | } else { | 163 | } else { |
| 164 | self.respond_standard_req(client_id, &subscription_id, &[ | 164 | self.respond_standard_req( |
| 165 | filter.clone() | 165 | client_id, |
| 166 | ])?; | 166 | &subscription_id, |
| 167 | &[filter.clone()], | ||
| 168 | )?; | ||
| 167 | // self.respond_eose(client_id, subscription_id)?; | 169 | // self.respond_eose(client_id, subscription_id)?; |
| 168 | } | 170 | } |
| 169 | // respond with events | 171 | // respond with events |
| @@ -186,7 +188,7 @@ impl<'a> Relay<'a> { | |||
| 186 | 188 | ||
| 187 | pub fn shutdown_relay(port: u64) -> Result<()> { | 189 | pub fn shutdown_relay(port: u64) -> Result<()> { |
| 188 | let mut counter = 0; | 190 | let mut counter = 0; |
| 189 | while let Ok((mut socket, _)) = tungstenite::connect(format!("ws://localhost:{}", port)) { | 191 | while let Ok((mut socket, _)) = tungstenite::connect(format!("ws://localhost:{port}")) { |
| 190 | counter += 1; | 192 | counter += 1; |
| 191 | if counter == 1 { | 193 | if counter == 1 { |
| 192 | socket.write(tungstenite::Message::text("shut me down"))?; | 194 | socket.write(tungstenite::Message::text("shut me down"))?; |