fn filter<MI, F>(self, function: F) -> Filter<F, Self>
    where
        F: Fn(MI) -> Option<M> + Sync,
    {
        Filter {
            function,
            target: self,
        }
    }
/// Apply a map/filter function to incoming messages.
///
/// TODO: Doc test
Apply a map/filter function to incoming messages.
TODO: Doc test
Apply a map / filter function to incoming messages . TODO : Doc test
fn filter<MI, F>(self, function: F) -> Filter<F, Self>
    where
        F: Fn(MI) -> Option<M> + Sync,
    {
        Filter {
            function,
            target: self,
        }
    }
fn filter < MI , F > ( self , function : F ) -> Filter < F , Self > where F : Fn ( MI ) -> Option < M > + Sync , { Filter { function , target : self , } }
Apply a map/filter function to incoming messages.
Apply a map / filter function to incoming messages .
self
function
F