volo_grpc/
message.rs

1use bytes::Bytes;
2use http_body::Frame;
3
4use crate::{
5    body::BoxBody,
6    codec::{compression::CompressionEncoding, decode::Kind},
7};
8
9pub trait SendEntryMessage {
10    fn into_body(
11        self,
12        compression_config: Option<CompressionEncoding>,
13    ) -> crate::BoxStream<'static, Result<Frame<Bytes>, crate::Status>>;
14}
15
16#[allow(clippy::result_large_err)]
17pub trait RecvEntryMessage: Sized {
18    fn from_body(
19        method: Option<&str>,
20        body: BoxBody,
21        kind: Kind,
22        compression_encoding: Option<CompressionEncoding>,
23    ) -> Result<Self, crate::Status>;
24}