1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
use super::*;
use std::marker::PhantomData;
impl<SD: SendDescUnicast, IC> SendDescUnicast for UriHostPath<SD, IC> {}
impl<SD: SendDescMulticast, IC> SendDescMulticast for UriHostPath<SD, IC> {}
#[derive(Debug)]
pub struct UriHostPath<SD, IC> {
pub(super) inner: SD,
pub(super) host: Option<String>,
pub(super) path_and_query: RelRefBuf,
pub(super) phantom: PhantomData<IC>,
}
impl<SD, IC, R> SendDesc<IC, R> for UriHostPath<SD, IC>
where
SD: SendDesc<IC, R>,
IC: InboundContext,
R: Send,
{
send_desc_passthru_timing!(inner);
send_desc_passthru_handler!(inner, R);
send_desc_passthru_payload!(inner);
fn write_options(
&self,
msg: &mut dyn OptionInsert,
socket_addr: &IC::SocketAddr,
start: Bound<OptionNumber>,
end: Bound<OptionNumber>,
) -> Result<(), Error> {
let mut unescape_buf;
write_options!((msg, socket_addr, start, end, self.inner) {
URI_HOST => self.host.iter(),
URI_PATH => {
unescape_buf = self.path_and_query.clone().into_unescape_buf();
unescape_buf.path_segments()
},
URI_QUERY => {
unescape_buf = self.path_and_query.clone().into_unescape_buf();
unescape_buf.query_items()
},
})
}
}