Struct exocore_transport::messages::InMessage [−][src]
pub struct InMessage {
pub source: Node,
pub cell_id: CellId,
pub service_type: ServiceType,
pub rendez_vous_id: Option<RendezVousId>,
pub typ: u16,
pub connection: Option<ConnectionId>,
pub envelope: TypedCapnpFrame<Bytes, Owned>,
pub stream: Option<MessageStream>,
}
Expand description
Message receive from another node.
Fields
source: Node
cell_id: CellId
service_type: ServiceType
rendez_vous_id: Option<RendezVousId>
typ: u16
connection: Option<ConnectionId>
envelope: TypedCapnpFrame<Bytes, Owned>
stream: Option<MessageStream>
Implementations
pub fn from_node_and_frame<I: FrameReader<OwnedType = Bytes>>(
from: Node,
envelope: TypedCapnpFrame<I, Owned>
) -> Result<InMessage, Error>
pub fn get_data_as_framed_message<'d, T>(
&'d self
) -> Result<TypedCapnpFrame<&'d [u8], T>, Error> where
T: for<'a> MessageType<'a>,
pub fn to_response_message<T>(
&self,
cell: &Cell,
frame: CapnpFrameBuilder<T>
) -> Result<OutMessage, Error> where
T: for<'a> MessageType<'a>,
Auto Trait Implementations
impl !RefUnwindSafe for InMessage
impl !UnwindSafe for InMessage
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more