diff --git a/worterbuch-client/src/lib.rs b/worterbuch-client/src/lib.rs index 6cf807a..4735870 100644 --- a/worterbuch-client/src/lib.rs +++ b/worterbuch-client/src/lib.rs @@ -1414,7 +1414,7 @@ async fn process_incoming_server_message( SM::PState(pstate) => deliver_pstate(pstate, callbacks).await?, SM::LsState(ls) => deliver_ls(ls, callbacks).await?, SM::Err(err) => deliver_err(err, callbacks).await, - SM::Ack(_) | SM::Welcome(_) | SM::Authorized(_) | SM::Keepalive => (), + SM::Ack(_) | SM::Welcome(_) | SM::Authorized(_) => (), } Ok(ControlFlow::Continue(())) } diff --git a/worterbuch-common/src/client.rs b/worterbuch-common/src/client.rs index 8078a91..c366607 100644 --- a/worterbuch-common/src/client.rs +++ b/worterbuch-common/src/client.rs @@ -40,8 +40,6 @@ pub enum ClientMessage { SubscribeLs(SubscribeLs), UnsubscribeLs(UnsubscribeLs), Transform(Transform), - #[serde(rename = "")] - Keepalive, } impl ClientMessage { @@ -64,7 +62,6 @@ impl ClientMessage { ClientMessage::SubscribeLs(m) => Some(m.transaction_id), ClientMessage::UnsubscribeLs(m) => Some(m.transaction_id), ClientMessage::Transform(m) => Some(m.transaction_id), - ClientMessage::Keepalive => None, } } } diff --git a/worterbuch-common/src/lib.rs b/worterbuch-common/src/lib.rs index 099603c..5458068 100644 --- a/worterbuch-common/src/lib.rs +++ b/worterbuch-common/src/lib.rs @@ -310,7 +310,7 @@ pub fn digest_token(auth_token: &Option, client_id: String) -> Option Some(msg.transaction_id), ServerMessage::LsState(msg) => Some(msg.transaction_id), ServerMessage::Authorized(_) => Some(0), - ServerMessage::Keepalive => None, } } } diff --git a/worterbuch/src/server/common.rs b/worterbuch/src/server/common.rs index a9c7173..49106c8 100644 --- a/worterbuch/src/server/common.rs +++ b/worterbuch/src/server/common.rs @@ -329,7 +329,6 @@ pub async fn process_incoming_message( // TODO return Ok((false, authorized)); } - CM::Keepalive => (), }, Ok(None) => { // client disconnected