mirror of
https://github.com/mikedilger/gossip.git
synced 2024-09-29 16:31:18 +00:00
Move some trace messages to before the call that is likely to be problematic (instead of after)
This commit is contained in:
parent
80d88cc27a
commit
a72c9a2e64
@ -802,8 +802,8 @@ impl Minion {
|
||||
let req_message = self.subscriptions.get(handle).unwrap().req_message();
|
||||
let wire = serde_json::to_string(&req_message)?;
|
||||
let websocket_sink = self.sink.as_mut().unwrap();
|
||||
tracing::trace!("{}: Sending {}", &self.url, &wire);
|
||||
websocket_sink.send(WsMessage::Text(wire.clone())).await?;
|
||||
tracing::trace!("{}: Sent {}", &self.url, &wire);
|
||||
Ok(())
|
||||
}
|
||||
|
||||
@ -814,8 +814,8 @@ impl Minion {
|
||||
let close_message = self.subscriptions.get(handle).unwrap().close_message();
|
||||
let wire = serde_json::to_string(&close_message)?;
|
||||
let websocket_sink = self.sink.as_mut().unwrap();
|
||||
tracing::trace!("{}: Sending {}", &self.url, &wire);
|
||||
websocket_sink.send(WsMessage::Text(wire.clone())).await?;
|
||||
tracing::trace!("{}: Sent {}", &self.url, &wire);
|
||||
self.subscriptions.remove(handle);
|
||||
Ok(())
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user