|
@@ -191,6 +191,11 @@ impl Client {
|
|
|
continue
|
|
continue
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ // If this event was seen, skip it
|
|
|
|
|
+ if self.seen.get().unwrap().contains_key(event_id.as_bytes()).unwrap() {
|
|
|
|
|
+ continue
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
// Try to deserialize the `Event`'s content into a `Privmsg`
|
|
// Try to deserialize the `Event`'s content into a `Privmsg`
|
|
|
let mut privmsg: Privmsg = match deserialize_async_partial(r.content()).await {
|
|
let mut privmsg: Privmsg = match deserialize_async_partial(r.content()).await {
|
|
|
Ok((v, _)) => v,
|
|
Ok((v, _)) => v,
|