Struct OnClose

pub struct OnClose(pub bool);

Sent by Connection after CLS is sent to nsqd

Examples

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

struct Consumer(pub Addr<Connection>);

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

impl Handler<OnClose> for Consumer {
    type Result = ();
    fn handle(&mut self, msg: OnClose, ctx: &mut Self::Conetxt) {
        if msg.0 == true {
            println!("connection closed");
        } else {
            println!("connection closing failed");
        }
    }
}

Tuple Fields

0: bool

Trait Implementations

impl Clone for OnClose

fn clone(&self) -> OnClose

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Message for OnClose

type Result = ()

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