Struct nanocurrency_peering::PeeringManagerBuilder
[−]
[src]
pub struct PeeringManagerBuilder<F, I, II> where
I: Iterator<Item = (Message, SocketAddr)>,
II: IntoIterator<Item = (Message, SocketAddr), IntoIter = I>,
F: Fn(&PeeringManagerState, MessageHeader, Message, SocketAddr) -> II + 'static, { /* fields omitted */ }
Methods
impl<F, I, II> PeeringManagerBuilder<F, I, II> where
I: Iterator<Item = (Message, SocketAddr)>,
II: IntoIterator<Item = (Message, SocketAddr), IntoIter = I>,
F: Fn(&PeeringManagerState, MessageHeader, Message, SocketAddr) -> II + 'static, [src]
I: Iterator<Item = (Message, SocketAddr)>,
II: IntoIterator<Item = (Message, SocketAddr), IntoIter = I>,
F: Fn(&PeeringManagerState, MessageHeader, Message, SocketAddr) -> II + 'static,
pub fn new(message_handler: F) -> PeeringManagerBuilder<F, I, II>[src]
pub fn use_official_peers(self, value: bool) -> Self[src]
pub fn custom_peers(self, value: Vec<SocketAddr>) -> Self[src]
pub fn listen_addr(self, value: SocketAddr) -> Self[src]
pub fn network(self, value: Network) -> Self[src]
pub fn state_base(self, value: Rc<RefCell<PeeringManagerState>>) -> Self[src]
pub fn send_messages(
self,
value: Box<Stream<Item = (Message, SocketAddr), Error = ()>>
) -> Self[src]
self,
value: Box<Stream<Item = (Message, SocketAddr), Error = ()>>
) -> Self