This adds unnecessary complexity to code.
fn from_str(s: &str) -> Result<Self, Self::Err> {
let su = s.to_uppercase();
- let su_slice: &str = &*su;
+ let su_slice: &str = &su;
match su_slice {
"DATA" => Ok(HTTP2FrameType::DATA),
"HEADERS" => Ok(HTTP2FrameType::HEADERS),
fn from_str(s: &str) -> Result<Self, Self::Err> {
let su = s.to_uppercase();
- let su_slice: &str = &*su;
+ let su_slice: &str = &su;
match su_slice {
"NO_ERROR" => Ok(HTTP2ErrorCode::NOERROR),
"PROTOCOL_ERROR" => Ok(HTTP2ErrorCode::PROTOCOLERROR),
fn from_str(s: &str) -> Result<Self, Self::Err> {
let su = s.to_uppercase();
- let su_slice: &str = &*su;
+ let su_slice: &str = &su;
match su_slice {
"SETTINGS_HEADER_TABLE_SIZE" => Ok(HTTP2SettingsId::SETTINGSHEADERTABLESIZE),
"SETTINGS_ENABLE_PUSH" => Ok(HTTP2SettingsId::SETTINGSENABLEPUSH),
}
MQTTOperation::CONNACK(ref _connack) => {
if let Some(tx) = self.get_tx_by_pkt_id(MQTT_CONNECT_PKT_ID) {
- (*tx).msg.push(msg);
- (*tx).complete = true;
- (*tx).pkt_id = None;
+ tx.msg.push(msg);
+ tx.complete = true;
+ tx.pkt_id = None;
self.connected = true;
} else {
let mut tx = self.new_tx(msg, toclient);
return;
}
if let Some(tx) = self.get_tx_by_pkt_id(v.message_id as u32) {
- (*tx).msg.push(msg);
+ tx.msg.push(msg);
} else {
let mut tx = self.new_tx(msg, toclient);
MQTTState::set_event(&mut tx, MQTTEvent::MissingPublish);
return;
}
if let Some(tx) = self.get_tx_by_pkt_id(v.message_id as u32) {
- (*tx).msg.push(msg);
- (*tx).complete = true;
- (*tx).pkt_id = None;
+ tx.msg.push(msg);
+ tx.complete = true;
+ tx.pkt_id = None;
} else {
let mut tx = self.new_tx(msg, toclient);
MQTTState::set_event(&mut tx, MQTTEvent::MissingPublish);
return;
}
if let Some(tx) = self.get_tx_by_pkt_id(suback.message_id as u32) {
- (*tx).msg.push(msg);
- (*tx).complete = true;
- (*tx).pkt_id = None;
+ tx.msg.push(msg);
+ tx.complete = true;
+ tx.pkt_id = None;
} else {
let mut tx = self.new_tx(msg, toclient);
MQTTState::set_event(&mut tx, MQTTEvent::MissingSubscribe);
return;
}
if let Some(tx) = self.get_tx_by_pkt_id(unsuback.message_id as u32) {
- (*tx).msg.push(msg);
- (*tx).complete = true;
- (*tx).pkt_id = None;
+ tx.msg.push(msg);
+ tx.complete = true;
+ tx.pkt_id = None;
} else {
let mut tx = self.new_tx(msg, toclient);
MQTTState::set_event(&mut tx, MQTTEvent::MissingUnsubscribe);
type Err = String;
fn from_str(s: &str) -> Result<Self, Self::Err> {
let su = s.to_uppercase();
- let su_slice: &str = &*su;
+ let su_slice: &str = &su;
match su_slice {
"CONNECT" => Ok(MQTTTypeCode::CONNECT),
"CONNACK" => Ok(MQTTTypeCode::CONNACK),