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
use crate::common::stream_handler::StreamHandlerInternal;
use crate::error;
use crate::result;
use crate::ErrorCode;
use crate::Headers;
use bytes::Bytes;
pub trait ServerRequestStreamHandler: Send + 'static {
fn data_frame(&mut self, data: Bytes, end_stream: bool) -> result::Result<()>;
fn trailers(&mut self, trailers: Headers) -> result::Result<()>;
fn rst(&mut self, error_code: ErrorCode) -> result::Result<()> {
self.error(error::Error::CodeError(error_code))
}
fn error(&mut self, error: error::Error) -> result::Result<()>;
}
pub(crate) struct ServerRequestStreamHandlerHolder(pub(crate) Box<dyn ServerRequestStreamHandler>);
impl StreamHandlerInternal for ServerRequestStreamHandlerHolder {
fn data_frame(&mut self, data: Bytes, end_stream: bool) -> result::Result<()> {
self.0.data_frame(data, end_stream)
}
fn trailers(&mut self, trailers: Headers) -> result::Result<()> {
self.0.trailers(trailers)
}
fn rst(mut self, error_code: ErrorCode) -> result::Result<()> {
self.0.rst(error_code)
}
fn error(mut self, error: error::Error) -> result::Result<()> {
self.0.error(error)
}
}