diff options
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"))?; |