cram 0.1.2

Cram realy awesome middleware
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

mod thread_message;
mod thread_pool;

use std::sync::Arc;
use crossbeam::crossbeam_channel::Sender;
use std::boxed::Box;

/// /// info to send to about stateful or stateless /// ///

struct Stateful{
    fun : Box<FnMut(Vec<u8>) + Send +  Sync + 'static>,
    message : Vec<u8>,
    sender : Sender< (Option<String>, Box<FnMut(Vec<u8>) + Send +  Sync + 'static>) >,
    label : Option<String>,
}

struct Stateless{
    fun : Arc<Box<Fn(Vec<u8>) + Send +  Sync + 'static>>,
    message : Vec<u8>,
}

/// /// Message to send to threadPoll /// ///

pub struct ThreadMessage{
    is_stateless : bool,    
    stateful_info : Option<Stateful>,
    statefless_info : Option<Stateless>,
}

pub struct ThreadPool{
    input_channel : Sender<ThreadMessage>,
}