Messages

 
pub struct OriginMessage {
    pub respond_to: oneshot::Sender<Message>,
    pub session: Option<String>,
    pub mpsc_respond_to: Option<mpsc::Sender<Message>>,
}

pub enum Message {
    Split {
        message: Vec<u8>,
        respond_to: Arc<mpsc::Sender<Message>>,
        origin: Option<OriginMessage>,
    },
    Exit {
        origin: Option<OriginMessage>,
    },
    Standard {
        message: Vec<u8>,
        origin: Option<OriginMessage>,
    },
    HTTP {
        message: Vec<u8>,
        status: u16,
        headers: HashMap<String, String>,
        origin: Option<OriginMessage>,
    },
 
    JSON {
        message: Value,
        origin: Option<OriginMessage>,
    },
    ReqReply {
        path: String,
        query: String,
        method: String,
        message: Vec<u8>,
        respond_to: oneshot::Sender<Message>,
    },
    Init {
        id: String,
        next: Vec<Arc<Mutex<dyn Operator>>>,
        end: Arc<Mutex<dyn Operator + 'static>>,
        start: Arc<Mutex<dyn Operator + 'static>>,
    },
    Error {
        error: String,
    },
    NoOp {},
}