Trait nakamoto_net::Reactor

pub trait Reactor<Id: PeerId = SocketAddr> {
    type Waker: Waker;

    fn new(
        shutdown: Receiver<()>,
        listening: Sender<SocketAddr>
    ) -> Result<Self, Error>
    where
        Self: Sized;
    fn run<S, E>(
        &mut self,
        listen_addrs: &[SocketAddr],
        service: S,
        publisher: E,
        commands: Receiver<S::Command>
    ) -> Result<(), Error>
    where
        S: Service<Id>,
        S::DisconnectReason: Into<Disconnect<S::DisconnectReason>>,
        E: Publisher<S::Event>;
    fn waker(&self) -> Self::Waker;
}

Any network reactor that can drive the light-client service.

Required Associated Types

type Waker: Waker

The type of waker this reactor uses.

Required Methods

fn new(
    shutdown: Receiver<()>,
    listening: Sender<SocketAddr>
) -> Result<Self, Error>where
    Self: Sized,

Create a new reactor, initializing it with a publisher for service events, a channel to receive commands, and a channel to shut it down.

fn run<S, E>(
    &mut self,
    listen_addrs: &[SocketAddr],
    service: S,
    publisher: E,
    commands: Receiver<S::Command>
) -> Result<(), Error>where
    S: Service<Id>,
    S::DisconnectReason: Into<Disconnect<S::DisconnectReason>>,
    E: Publisher<S::Event>,

Run the given service with the reactor.

Takes:

• The addresses to listen for connections on.
• The Service to run.
• The StateMachine::Event publisher to use when the service emits events.
• The Service::Command channel on which commands will be received.

fn waker(&self) -> Self::Waker

Return a new waker.

The reactor can provide multiple wakers such that multiple user threads may wake the event loop.

Implementors