Skip to content

Commit

Permalink
feat: clippy clear
Browse files Browse the repository at this point in the history
  • Loading branch information
technobaboo committed Feb 26, 2025
1 parent e71603d commit 461295d
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 9 deletions.
2 changes: 1 addition & 1 deletion gen/src/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ pub fn generate_client_code(current: &[Pair], pairs: &[Pair]) -> TokenStream {
let name = &interface.name;
let version = &interface.version;

let enums = write_enums(&interface);
let enums = write_enums(interface);

let requests = write_requests(pairs, pair, interface);
let events = write_events(pairs, pair, interface);
Expand Down
3 changes: 1 addition & 2 deletions gen/src/parser.rs
Original file line number Diff line number Diff line change
Expand Up @@ -186,8 +186,7 @@ impl Arg {
pair.protocol
.interfaces
.iter()
.find(|e| e.name == enum_interface)
.is_some()
.any(|e| e.name == enum_interface)
})
.unwrap()
.clone(),
Expand Down
12 changes: 6 additions & 6 deletions gen/src/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,10 +30,10 @@ pub fn generate_server_code(current: &[Pair], pairs: &[Pair]) -> TokenStream {
let name = &interface.name;
let version = &interface.version;

let dispatchers = write_dispatchers(&interface);
let requests = write_requests(pairs, pair, &interface);
let events = write_events(pairs, pair, &interface);
let enums = write_enums(&interface);
let dispatchers = write_dispatchers(interface);
let requests = write_requests(pairs, pair, interface);
let events = write_events(pairs, pair, interface);
let enums = write_enums(interface);

let handler_args = if dispatchers.is_empty() {
quote! {
Expand Down Expand Up @@ -104,7 +104,7 @@ fn write_dispatchers(interface: &Interface) -> Vec<TokenStream> {

for (opcode, request) in interface.requests.iter().enumerate() {
let opcode = opcode as u16;
let name = make_ident(&request.name.to_snek_case());
let name = make_ident(request.name.to_snek_case());

let mut tracing_fmt = Vec::new();
let mut tracing_args = Vec::new();
Expand Down Expand Up @@ -228,7 +228,7 @@ fn write_events(pairs: &[Pair], pair: &Pair, interface: &Interface) -> Vec<Token
let mut tracing_args = Vec::new();

for arg in &event.args {
let mut ty = arg.to_rust_type_token(arg.find_protocol(&pairs).as_ref().unwrap_or(pair));
let mut ty = arg.to_rust_type_token(arg.find_protocol(pairs).as_ref().unwrap_or(pair));

let mut map_display = quote! {};

Expand Down
2 changes: 2 additions & 0 deletions src/wire/message.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ use std::os::fd::RawFd;
use bytes::{Buf, BufMut, Bytes, BytesMut};
use rustix::fd::{FromRawFd, OwnedFd};

#[cfg(feature = "server")]
use crate::server::Client;

use super::{DecodeError, Fixed, NewId, ObjectId};
Expand Down Expand Up @@ -155,6 +156,7 @@ impl Message {
.ok_or(DecodeError::MalformedPayload)
}

#[cfg(feature = "server")]
pub async fn send(self, client: &mut Client) -> std::io::Result<()> {
client.send_message(self).await
}
Expand Down

0 comments on commit 461295d

Please sign in to comment.