Struct actix_nats::RequestWithReply

pub struct RequestWithReply { /* fields omitted */ }

RequestWithReply creates a reply inbox in NATS, publishes a message (Request in terms of NATS grammar) and waits for the reply to come back.

Methods

impl RequestWithReply

pub fn new(subject: String, data: Vec<u8>) -> Self

Trait Implementations

impl Message for RequestWithReply

type Result = Result<Vec<u8>, NatsError>

The type of value that this message will resolved with if it is successful.

impl Handler<RequestWithReply> for NATSExecutorSync

type Result = Result<Vec<u8>, NatsError>

The type of value that this handle will return

fn handle(     &mut self,     msg: RequestWithReply,     _: &mut Self::Context ) -> Self::Result

Method is called for every message received by this Actor