Struct FetchThread 

pub(crate) struct FetchThread {
    pub(crate) active_fetches: FxHashMap<RequestId, BoxedFetchCallback>,
    pub(crate) receiver: Receiver<ToFetchThreadMessage>,
    pub(crate) to_fetch_sender: IpcSender<FetchResponseMsg>,
}

A thread to handle fetches in a Servo process. This thread is responsible for listening for new fetch requests as well as updates on those operations and forwarding them to crossbeam channels.

Fields

active_fetches: FxHashMap<RequestId, BoxedFetchCallback>

A list of active fetches. A fetch is no longer active once the FetchResponseMsg::ProcessResponseEOF is received.

receiver: Receiver<ToFetchThreadMessage>

A crossbeam receiver attached to the router proxy which converts incoming fetch updates from IPC messages to crossbeam messages as well as another sender which handles requests from clients wanting to do fetches.

to_fetch_sender: IpcSender<FetchResponseMsg>

An IpcSender that’s sent with every fetch request and leads back to our router proxy.

Implementations

impl FetchThread

pub(crate) fn spawn() -> (Sender<ToFetchThreadMessage>, JoinHandle<()>)

pub(crate) fn run(&mut self)