236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
|
let response = builder.send().await.stack()?;
#[cfg(debug_assertions)]
{
let headers = response.headers();
let expires = headers.get(EXPIRES);
let cache = headers.get(CACHE_CONTROL);
if expires.is_some() || cache.is_some() {
println!("{} {} {:?} {:?} {:?}", Local::now().to_rfc2822(), &source.url, last_scrape, expires, cache);
}
}
let status = response.status();
let content = response.bytes().await.stack()?;
match rss::Channel::read_from(&content[..]) {
Ok(feed) => {
for item in feed.items() {
|
|
|
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
|
let response = builder.send().await.stack()?;
#[cfg(debug_assertions)]
{
let headers = response.headers();
let expires = headers.get(EXPIRES);
let cache = headers.get(CACHE_CONTROL);
if expires.is_some() || cache.is_some() {
println!("{} {} {:?} {:?} {:?}", Local::now().to_rfc2822(), source.url, last_scrape, expires, cache);
}
}
let status = response.status();
let content = response.bytes().await.stack()?;
match rss::Channel::read_from(&content[..]) {
Ok(feed) => {
for item in feed.items() {
|