fix futures-lite panic
This commit is contained in:
parent
0c1a104cea
commit
5bff10aa3c
1 changed files with 1 additions and 0 deletions
|
|
@ -32,6 +32,7 @@ pub async fn event_consumer(tx: channel::Sender<Event>) -> Result<()> {
|
|||
let event: Event = serde_json::from_str(&buf)?;
|
||||
tracing::trace!("event: {:?}", event);
|
||||
tx.send(event).await?;
|
||||
buf.clear();
|
||||
}
|
||||
unreachable!("Listener loop ended");
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue