Struct alewife::Subscriber [−] [src]

pub struct Subscriber<Topic, Content> {
    // some fields omitted
}

Interface for receiving messages from the network. Created by calling Builder::add_subscriber() during network setup.

Methods

impl<Topic, Content> Subscriber<Topic, Content>
[src]

fn fetch(&self) -> Vec<(Topic, Content)>

Consumes all pending messages in the subscriber's inbox.