Fix some warnings

This commit is contained in:
Joscha 2022-08-02 01:38:32 +02:00
parent 18573e5a37
commit 9ac646174c
4 changed files with 8 additions and 13 deletions

View file

@ -32,7 +32,7 @@ pub enum Error {
enum Event {
Connected(ConnTx),
Disconnected,
Data(Data),
Data(Box<Data>),
Status(oneshot::Sender<Option<Status>>),
RequestLogs,
Nick(String),
@ -85,7 +85,7 @@ impl State {
event_tx.send(Event::Connected(conn_tx))?;
while let Ok(data) = conn_rx.recv().await {
event_tx.send(Event::Data(data))?;
event_tx.send(Event::Data(Box::new(data)))?;
}
info!("e&{}: disconnected", name);
@ -160,7 +160,7 @@ impl State {
self.conn_tx = None;
self.last_msg_id = None;
}
Event::Data(data) => self.on_data(data).await?,
Event::Data(data) => self.on_data(*data).await?,
Event::Status(reply_tx) => self.on_status(reply_tx).await,
Event::RequestLogs => self.on_request_logs(),
Event::Nick(name) => self.on_nick(name),
@ -342,12 +342,6 @@ impl Room {
rx.await.map_err(|_| Error::Stopped)
}
pub fn request_logs(&self) -> Result<(), Error> {
self.event_tx
.send(Event::RequestLogs)
.map_err(|_| Error::Stopped)
}
pub fn nick(&self, name: String) -> Result<(), Error> {
self.event_tx
.send(Event::Nick(name))