Struct kompact::prelude::Ask

pub struct Ask<Request, Response> where
    Request: MessageBounds,
    Response: Send + Sized,  { /* fields omitted */ }

A message type for request-response messages.

Used together with the ask function.

Implementations

impl<Request, Response> Ask<Request, Response> where
    Request: MessageBounds,
    Response: Send + Sized, 

pub fn new(
    promise: KPromise<Response>,
    content: Request
) -> Ask<Request, Response>

Produce a new Ask instance from a promise and a Request.

pub fn of(
    content: Request
) -> impl FnOnce(KPromise<Response>) -> Ask<Request, Response>

Produce a function that takes a promise and returns an ask with the given Request.

Use this avoid the explicit chaining of the promise that the new function requires.

pub fn request(&self) -> &Request

The request associated with this Ask.

pub fn request_mut(&mut self) -> &mut Request

The request associated with this Ask (mutable).

pub fn take(self) -> (KPromise<Response>, Request)

Decompose this Ask into a pair of a promise and a Request.

pub fn reply(self, response: Response) -> Result<(), PromiseErr>

Reply to this Ask with the response.

Fails with a PromiseErr if the promise has already been fulfilled or the other end dropped the future.

pub fn complete<F>(self, f: F) -> Result<(), PromiseErr> where
    F: FnOnce(Request) -> Response, 

Run f to produce a response to this Ask and reply with that reponse.

Fails with a PromiseErr if the promise has already been fulfilled or the other end dropped the future.

Trait Implementations

impl<Request: Debug, Response: Debug> Debug for Ask<Request, Response> where
    Request: MessageBounds,
    Response: Send + Sized, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.