Struct ipc_communication::Processors

#[must_use = "One must call process requests in order for the communication to run"]
pub struct Processors<Request, Response> {
    pub processors: Vec<Processor<Request, Response>>,
}

Request processors.

Fields

processors: Vec<Processor<Request, Response>>

The underlying processors.

Methods

impl<Request, Response> Processors<Request, Response> where
    Request: Serialize,
    Request: Deserialize<'de>,
    Response: Serialize,
    Response: Deserialize<'de>,
    Request: Send,
    Response: Send, 

pub fn run_in_parallel<S, State, F>(
    self,
    setup: S,
    f: F
) -> Result<(), Vec<ParallelRunError>> where
    S: FnMut() -> State,
    F: Fn(&mut State, Request) -> Response,
    F: Send + Sync,
    State: Send, 

Runs all the underlying responses in separate thread each using a given closure.