src/schema/mod.rs

   1 mod message;
   2
   3 pub use message::ConnectionMessage;
   4 use protobuf::well_known_types::Any;
   5 use protobuf::Message;
   6
   7 impl ConnectionMessage {
   8     pub(crate) fn from_msg<M: Message>(msg: M) -> Self {
   9         let mut sm = Self::new();
  10         let payload = Any::pack(&msg).expect("Protobuf Message could not be packed into Any type");
  11
  12         sm.set_payload(payload);
  13         return sm;
  14     }
  15 }