Struct Subscriber 

pub struct Subscriber<T>
where
    T: TryFrom<Message> + Send + Sync + 'static,
    T::Error: Error + 'static,
{
    thread: JoinHandle<()>,
    rx: Receiver<T>,
}

Fields

thread: JoinHandle<()>

rx: Receiver<T>

Implementations

impl<T> Subscriber<T>

where T: TryFrom<Message> + Send + Sync + 'static, T::Error: Error + 'static,

pub fn new(recv_address: String) -> Result<Self>

pub fn recv(&self) -> Result<T>

pub fn gen_recv(self) -> impl FnMut() -> Result<T, Box<dyn Error>>

pub fn join(self) -> Result<(), Box<dyn Any + Send + 'static>>

Trait Implementations

impl<T> PipelineLayer<T> for Subscriber<T>

where T: TryFrom<Message> + Send + Sync + 'static, T::Error: Error + 'static,

fn to<R: Sync + Send + 'static, C>(self, c: C) -> impl PipelineLayer<R>

where C: Fn(T) -> Result<R, Box<dyn Error>> + Sync + Send + 'static,

fn map_to<R: Sync + Send + 'static, C>(self, c: C) -> impl PipelineLayer<R>

where C: Fn(T) -> Vec<R> + Sync + Send + 'static,

fn finish<C>(self, c: C) -> Vec<JoinHandle<()>>

where C: FnMut(T) -> Result<(), Box<dyn Error>> + Send + 'static,