camel-api 0.6.2

Core traits and interfaces for rust-camel
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use crate::exchange::Exchange;
use std::sync::Arc;

/// Predicate that determines whether an exchange passes the filter.
/// Returns `true` to forward the exchange into the filter body; `false` to skip it.
pub type FilterPredicate = Arc<dyn Fn(&Exchange) -> bool + Send + Sync>;

#[cfg(test)]
mod tests {
    use super::*;
    use crate::{Exchange, Message};

    #[test]
    fn test_filter_predicate_is_callable() {
        let pred: FilterPredicate = Arc::new(|ex: &Exchange| ex.input.body.as_text().is_some());
        let ex = Exchange::new(Message::new("hello"));
        assert!(pred(&ex));
    }
}