1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use bytes::Bytes;
use hyper::body::Incoming;

use crate::codec::{compression::CompressionEncoding, decode::Kind};

pub trait SendEntryMessage {
    fn into_body(
        self,
        compression_config: Option<CompressionEncoding>,
    ) -> crate::BoxStream<'static, Result<Bytes, crate::Status>>;
}

pub trait RecvEntryMessage: Sized {
    fn from_body(
        method: Option<&str>,
        body: Incoming,
        kind: Kind,
        compression_encoding: Option<CompressionEncoding>,
    ) -> Result<Self, crate::Status>;
}