Struct async_nats::service::Request

pub struct Request {
    pub message: Message,
    /* private fields */
}

Available on crate feature service only.

Request returned by Service [Stream][futures::Stream].

Fields

message: Message

Implementations

impl Request

pub async fn respond( self, response: Result<Bytes, Error> ) -> Result<(), PublishError>

Sends response for the request.

Examples

use async_nats::service::ServiceExt;
use futures::StreamExt;
let mut endpoint = service.endpoint("endpoint").await?;
let request = endpoint.next().await.unwrap();
request.respond(Ok("hello".into())).await?;

Trait Implementations

impl Debug for Request

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

Formats the value using the given formatter.