Trait nakamoto_node::client::Reactor

pub trait Reactor {
    type Waker: Waker;

    fn new(
        shutdown: Receiver<()>,
        listening: Sender<SocketAddr>
    ) -> Result<Self, Error>;
    fn run<P, E>(
        &mut self,
        listen_addrs: &[SocketAddr],
        protocol: P,
        publisher: E,
        commands: Receiver<<P as Protocol>::Command>
    ) -> Result<(), Error>
    where
        P: Protocol,
        E: Publisher<<P as Protocol>::Event>,
        <P as Protocol>::DisconnectReason: Into<DisconnectReason<<P as Protocol>::DisconnectReason>>;
    fn waker(&self) -> Self::Waker;
}

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

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>

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

fn run<P, E>(
    &mut self,
    listen_addrs: &[SocketAddr],
    protocol: P,
    publisher: E,
    commands: Receiver<<P as Protocol>::Command>
) -> Result<(), Error>where
    P: Protocol,
    E: Publisher<<P as Protocol>::Event>,
    <P as Protocol>::DisconnectReason: Into<DisconnectReason<<P as Protocol>::DisconnectReason>>,

Run the given protocol state machine with the reactor.

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

Return a new waker.

Implementations on Foreign Types

impl Reactor for Reactor<TcpStream>

fn new(
    shutdown: Receiver<()>,
    listening: Sender<SocketAddr>
) -> Result<Reactor<TcpStream>, Error>

Construct a new reactor, given a channel to send events on.

fn run<P, E>(
    &mut self,
    listen_addrs: &[SocketAddr],
    protocol: P,
    publisher: E,
    commands: Receiver<<P as Protocol>::Command>
) -> Result<(), Error>where
    P: Protocol,
    E: Publisher<<P as Protocol>::Event>,
    <P as Protocol>::DisconnectReason: Into<DisconnectReason<<P as Protocol>::DisconnectReason>>,

Run the given protocol with the reactor.

fn waker(&self) -> <Reactor<TcpStream> as Reactor>::Waker

Return a new waker.

Used to wake up the main event loop.

type Waker = Waker

Implementors