memberlist-proto 0.3.3

Proto types and traits for the memberlist crate.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use super::{super::Message, Data, EncodeError, Payload, ProtoEncoder, ProtoEncoderError};

impl<I, A, B> ProtoEncoder<I, A, B>
where
  I: Data + 'static,
  A: Data + 'static,
  B: AsRef<[Message<I, A>]> + Send + Sync + 'static,
{
  /// Encodes the messages.
  #[auto_enums::auto_enum(Iterator, Debug)]
  pub async fn blocking_encode<RT>(
    self,
  ) -> impl Iterator<Item = Result<Payload, ProtoEncoderError>> + 'static
  where
    RT: agnostic_lite::RuntimeLite,
  {
    let res = RT::spawn_blocking(move || self.encode().collect::<Vec<_>>()).await;

    match res {
      Ok(res) => res.into_iter(),
      Err(err) => core::iter::once(Err(EncodeError::custom(err.to_string()).into())),
    }
  }
}