queen 0.26.0

message queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use queen_io::net::tcp::TcpStream;

use nson::{Message, MessageId};

use crate::Wire;

pub trait Hook: Send + 'static {
    fn enable_secure(&self) -> bool { false }

    fn accept(&self, _: &mut TcpStream) -> bool { true }

    fn start(&self, _slot_id: MessageId, _root: bool, _: &mut Message) -> bool { true }

    fn access(&self, _slot_id: MessageId, _root: bool, _: &mut Message) -> Option<String> { None }

    fn finish(&self, _slot_id: MessageId, _root: bool, _: &mut Message, _: &Wire<Message>) { }
}

pub struct NonHook;

impl Hook for NonHook {}
impl Hook for () {}