Add ability to play DCA and Opus files. (#148)

1 files changed, 19 insertions, 16 deletions

diff --git a/src/http/ratelimiting.rs b/src/http/ratelimiting.rs
index 52762f5..039f15d 100644
--- a/src/http/ratelimiting.rs
+++ b/src/http/ratelimiting.rs
@@ -47,7 +47,7 @@ use hyper::status::StatusCode;
 use std::collections::HashMap;
 use std::sync::{Arc, Mutex};
 use std::time::Duration;
-use std::{str, thread, i64};
+use std::{i64, str, thread};
 use super::{HttpError, LightMethod};
 use internal::prelude::*;
 
@@ -399,16 +399,15 @@ pub(crate) fn perform<'a, F>(route: Route, f: F) -> Result<Response>
             let redo = if response.headers.get_raw("x-ratelimit-global").is_some() {
                 let _ = GLOBAL.lock().expect("global route lock poisoned");
 
-                Ok(
-                    if let Some(retry_after) = parse_header(&response.headers, "retry-after")? {
-                        debug!("Ratelimited on route {:?} for {:?}ms", route, retry_after);
-                        thread::sleep(Duration::from_millis(retry_after as u64));
+                Ok(if let Some(retry_after) =
+                    parse_header(&response.headers, "retry-after")? {
+                    debug!("Ratelimited on route {:?} for {:?}ms", route, retry_after);
+                    thread::sleep(Duration::from_millis(retry_after as u64));
 
-                        true
-                    } else {
-                        false
-                    },
-                )
+                    true
+                } else {
+                    false
+                })
             } else {
                 lock.post_hook(&response, &route)
             };
@@ -506,12 +505,16 @@ impl RateLimit {
 
 fn parse_header(headers: &Headers, header: &str) -> Result<Option<i64>> {
     match headers.get_raw(header) {
-        Some(header) => match str::from_utf8(&header[0]) {
-            Ok(v) => match v.parse::<i64>() {
-                Ok(v) => Ok(Some(v)),
-                Err(_) => Err(Error::Http(HttpError::RateLimitI64)),
-            },
-            Err(_) => Err(Error::Http(HttpError::RateLimitUtf8)),
+        Some(header) => {
+            match str::from_utf8(&header[0]) {
+                Ok(v) => {
+                    match v.parse::<i64>() {
+                        Ok(v) => Ok(Some(v)),
+                        Err(_) => Err(Error::Http(HttpError::RateLimitI64)),
+                    }
+                },
+                Err(_) => Err(Error::Http(HttpError::RateLimitUtf8)),
+            }
         },
         None => Ok(None),
     }