|
|
|
@ -210,7 +210,7 @@ impl Sending { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
let mut prefix = if *is_appservice { |
|
|
|
let mut prefix = if *is_appservice { |
|
|
|
"+".as_bytes().to_vec() |
|
|
|
b"+".to_vec() |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
Vec::new() |
|
|
|
Vec::new() |
|
|
|
}; |
|
|
|
}; |
|
|
|
@ -248,7 +248,7 @@ impl Sending { |
|
|
|
|
|
|
|
|
|
|
|
#[tracing::instrument(skip(self))] |
|
|
|
#[tracing::instrument(skip(self))] |
|
|
|
pub fn send_pdu_appservice(&self, appservice_id: &str, pdu_id: &[u8]) -> Result<()> { |
|
|
|
pub fn send_pdu_appservice(&self, appservice_id: &str, pdu_id: &[u8]) -> Result<()> { |
|
|
|
let mut key = "+".as_bytes().to_vec(); |
|
|
|
let mut key = b"+".to_vec(); |
|
|
|
key.extend_from_slice(appservice_id.as_bytes()); |
|
|
|
key.extend_from_slice(appservice_id.as_bytes()); |
|
|
|
key.push(0xff); |
|
|
|
key.push(0xff); |
|
|
|
key.extend_from_slice(pdu_id); |
|
|
|
key.extend_from_slice(pdu_id); |
|
|
|
|