connex 0.1.1

A tcp communication library that supports custom encryption and decryption and automatic reconnection.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use crate::core::filter::{Filter, error::FilterResult};

pub struct Pipeline {
    filters: Vec<Box<dyn Filter>>,
}

impl Pipeline {
    pub fn new() -> Self {
        Pipeline {
            filters: Vec::new(),
        }
    }

    pub fn add_filter(&mut self, filter: Box<dyn Filter>) {
        self.filters.push(filter);
    }

    pub fn process(&self, data: Vec<u8>) -> FilterResult<Vec<u8>> {
        self.filters
            .iter()
            .try_fold(data, |acc, filter| filter.process(acc))
    }
}