toxblh/podcasts
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Make a counterfeit rss Error.

Browse Source
This commit is contained in:
Jordan Petridis 2018-02-05 16:37:50 +02:00
parent e84e7df3f1
commit 34d7391363
No known key found for this signature in database
GPG Key ID: CEABAD9F5683B9A6
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hammond-data/src/errors.rs
View File

@ -31,6 +31,9 @@ pub enum DataError {
TLSError(#[cause] native_tls::Error), TLSError(#[cause] native_tls::Error),
#[fail(display = "IO Error: {}", _0)] #[fail(display = "IO Error: {}", _0)]
IOError(#[cause] io::Error), IOError(#[cause] io::Error),
#[fail(display = "RSS Error: {}", _0)]
// Rss::Error is not yet Sync
RssCrateError(String),
#[fail(display = "WANNABE BAIL ERROR: {}", _0)] #[fail(display = "WANNABE BAIL ERROR: {}", _0)]
DiscountBail(String), DiscountBail(String),
} }

3
hammond-data/src/models/source.rs
View File

@ -242,8 +242,7 @@ fn response_to_channel(
.map(|iter| iter.collect::<Vec<u8>>()) .map(|iter| iter.collect::<Vec<u8>>())
.map(|utf_8_bytes| String::from_utf8_lossy(&utf_8_bytes).into_owned()) .map(|utf_8_bytes| String::from_utf8_lossy(&utf_8_bytes).into_owned())
.and_then(|buf| { .and_then(|buf| {
Channel::from_str(&buf) Channel::from_str(&buf).or_else(|err| Err(DataError::RssCrateError(format!("{}", err))))
.or_else(|_| Err(DataError::DiscountBail(format!("RSS crate Error"))))
}); });
let cpu_chan = pool.spawn(chan); let cpu_chan = pool.spawn(chan);
Box::new(cpu_chan) Box::new(cpu_chan)