Struct RequestWithReply 

pub struct RequestWithReply { /* private fields */ }

Subscribe is a message that subscribes to a topic in the NATS queue Think of it as the Sub part in PubSub. RequestWithReply creates a reply inbox in NATS, publishes a message (Request in terms of NATS grammar) and waits for the reply to come back.

Implementations

impl RequestWithReply

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

Trait Implementations

impl Clone for RequestWithReply

fn clone(&self) -> RequestWithReply

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RequestWithReply

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

Formats the value using the given formatter.

impl Handler<RequestWithReply> for NATSActor

type Result = Box<dyn Future<Item = Message, Error = 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

impl Message for RequestWithReply

type Result = Result<Message, NatsError>

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