INNER CODE UNIT · Rust

on_request

eepnet/emissary · emissary-cli/src/proxy/http/mod.rs:261

    async fn on_request(&mut self, request: RequestContext) -> Result<(), (TcpStream, HttpError)> {
        let RequestContext {
            mut stream,
            request,
        } = request;

        let ((host, port), request) =
            match request.assemble(&self.address_book_handle, &self.outproxy).await {
                Ok((host, request)) => (host, request),
                Err(error) => return Err((stream, error)),
            };

        let future = self.session.connect_detached_with_options(
            &host,
            StreamOptions {
                dst_port: port.unwrap_or(80),
                ..Default::default()
            },

View source record →