unit.rs
Rust test marker or harnessimports crate::Request
SHA-256dd2ec0f54d9fdca641a6f9d20c43e20b173bcf9e77dee6b7c2403d4166009c28
MaleculeH₂(Cm₂F)Md₂(InPa)
Evidence
1use std::io::{self, Write};
2use std::time;
3
4use log::{debug, info};
5use qstring::QString;
6use url::Url;
7
8#[cfg(feature = "cookie")]
9use cookie::Cookie;
10
11#[cfg(feature = "cookie")]
12use crate::agent::AgentState;
13use crate::body::{self, BodySize, Payload, SizedReader};
14use crate::header;
15use crate::resolve::ArcResolver;
16use crate::stream::{self, connect_test, Stream};
17use crate::{Error, Header, Request, Response};
18
19/// It's a "unit of work". Maybe a bad name for it?
20///
21/// *Internal API*
⋯4 lines
78:57…
79 if (username != "" || password != "") && !req.has("authorization") {
80 let encoded = base64::encode(&format!("{}:{}", username, password));
81 extra.push(Header::new("Authorization", &format!("Basic {}", encoded)));
82 }
83
84 #[cfg(feature = "cookie")]
85 extra.extend(extract_cooki …
119:44…
120 self.req.agent.lock().unwrap().resolver.clone()
121 }
122
123 #[cfg(test)]
124 pub fn header(&self, name: &str) -> Option<&str> {
125 header::get_header(&self.headers, name)
126 }
127 #[cfg(test)]
128 …
348:57… {
349 write!(
350 prelude,
351 "User-Agent: ureq/{}\r\n",
352 env!("CARGO_PKG_VERSION")
353 )?;
354 }
355 if !header::has_header(&unit.headers, "accept") {
356 w …
369:40… g::from_utf8_lossy(&prelude));
370 // write all to the wire
371 stream.write_all(&prelude[..])?;
372
373 Ok(())
⋯5 lines