mprocs 0.9.2

TUI for running multiple processes
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use std::{fmt::Debug, marker::PhantomData};

use bytes::{BufMut, BytesMut};
use futures::SinkExt;
use serde::{de::DeserializeOwned, Serialize};
use tokio::io::AsyncWrite;
use tokio_util::codec::FramedWrite;

type DynWrite = dyn AsyncWrite + Unpin + Send + 'static;

pub struct MsgSender<T: Serialize> {
  writer: FramedWrite<Box<DynWrite>, MsgEncoder<T>>,
}

impl<T: Serialize + Send + Debug + 'static> MsgSender<T> {
  pub fn new<W: AsyncWrite + Unpin + Send + 'static>(write: W) -> Self {
    let write: Box<DynWrite> = Box::new(write);
    let framed =
      tokio_util::codec::FramedWrite::new(write, MsgEncoder::<T>::new());

    MsgSender { writer: framed }
  }
}

impl<T: Serialize + DeserializeOwned + Debug> MsgSender<T> {
  pub async fn send(&mut self, msg: T) -> anyhow::Result<()> {
    self.writer.send(msg).await?;
    Ok(())
  }
}

struct MsgEncoder<T: Serialize> {
  t: PhantomData<T>,
  buf: Vec<u8>,
}

impl<T: Serialize> MsgEncoder<T> {
  pub fn new() -> Self {
    MsgEncoder {
      t: PhantomData,
      buf: Vec::new(),
    }
  }
}

impl<T: Serialize + Debug> tokio_util::codec::Encoder<T> for MsgEncoder<T> {
  type Error = bincode::Error;

  fn encode(&mut self, item: T, dst: &mut BytesMut) -> Result<(), Self::Error> {
    bincode::serialize_into(&mut self.buf, &item)?;
    dst.put_u32(self.buf.len() as u32);
    dst.extend_from_slice(&self.buf);
    self.buf.clear();
    self.buf.shrink_to(8 * 1024);
    Ok(())
  }
}