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>>,
    pub router: Router<Request, Response>,
    // some fields omitted
}

Request processors.

Fields

processors: Vec<Processor<Request, Response>>

The underlying processors.

router: Router<Request, Response>

Requests router.

Methods

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

pub fn run_in_parallel<S>(
    self,
    socium: S
) -> Result<Vec<ParallelRunError>, ParallelRunError> where
    S: Socium<Request, Response> + Sync,
    S::Proletarian: Proletarian<Request, Response>, 

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