Struct ipc_channel::router::Router

struct Router {
    msg_receiver: Receiver<RouterMsg>,
    msg_wakeup_id: u64,
    ipc_receiver_set: IpcReceiverSet,
    handlers: HashMap<u64, RouterHandler>,
}

Router runs in its own thread listening for events. Adds events to its IpcReceiverSet and listens for events using select().

Fields

msg_receiver: Receiver<RouterMsg>

Get messages from RouterProxy.

msg_wakeup_id: u64

The ID/index of the special channel we use to identify messages from msg_receiver.

ipc_receiver_set: IpcReceiverSet

Set of all receivers which have been registered for us to select on.

handlers: HashMap<u64, RouterHandler>

Maps ids to their handler functions.

Implementations

impl Router

fn new( msg_receiver: Receiver<RouterMsg>, wakeup_receiver: IpcReceiver<()>, ) -> Router

fn run(&mut self)

Continuously loop waiting for wakeup signals from router proxy. Iterate over events either:

1. If a message comes in from our special wakeup_receiver (identified through msg_wakeup_id. Read message from msg_receiver and add a new receiver to our receiver set.
2. Call appropriate handler based on message id.
3. Remove handler once channel closes.