Struct nsq_client::Fin

pub struct Fin(pub String);

Send FIN command to nsqd

Args:

• id - id of the message

Examples

use actix::prelude::*;
use nsq_client::{Connection, Subscribe, Msg, Fin};

struct Consumer(pub Addr<Connection>);

impl Actor for Consumer {
    type Context = Context<Self>;
    fn started(&mut self, ctx: &mut Self::Context) {
        self.subscribe::<Msg>(ctx, self.0.clone());
    }
}

impl Handler<Msg> for Consumer {
    type Result = ();
    fn handle(&mut self, msg: Msg, ctx: &mut Self::Conetxt) {
        self.0.do_send(Fin(msg.id));
    }
}

Trait Implementations

impl Clone for Fin

fn clone(&self) -> Fin

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Message for Fin

type Result = ()

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

impl Handler<Fin> for Connection

type Result = ()

The type of value that this handle will return

fn handle(&mut self, msg: Fin, ctx: &mut Self::Context)

Method is called for every message received by this Actor