Enabled the threaded tokio runtime

Author: Kixiron

Cargo.lock

@@ -51,7 +51,7 @@ rusoto_credential = "0.43"
 
 # Async
 futures = "0.3"
-tokio = "0.2"
+tokio = { version = "0.2", features = ["rt-threaded"] }
 
 [target.'cfg(not(windows))'.dependencies]
 libc = "0.2"

Cargo.toml

@@ -54,8 +54,6 @@ impl TestS3 {
 
 impl Drop for TestS3 {
     fn drop(&mut self) {
-        let mut runtime = Runtime::new().unwrap();
-
         // delete the bucket when the test ends
         // this has to delete all the objects in the bucket first or min.io will give an error
         let inner = self.0.borrow();
@@ -64,7 +62,9 @@ impl Drop for TestS3 {
             ..Default::default()
         };
 
-        let objects = runtime
+        let objects = inner
+            .runtime
+            .handle()
             .block_on(inner.client.list_objects(list_req))
             .unwrap();
         assert!(!objects.is_truncated.unwrap_or(false));
@@ -76,7 +76,9 @@ impl Drop for TestS3 {
                 ..Default::default()
             };
 
-            runtime
+            inner
+                .runtime
+                .handle()
                 .block_on(inner.client.delete_object(delete_req))
                 .unwrap();
         }
@@ -85,7 +87,9 @@ impl Drop for TestS3 {
             bucket: inner.bucket.to_owned(),
         };
 
-        runtime
+        inner
+            .runtime
+            .handle()
             .block_on(inner.client.delete_bucket(delete_req))
             .expect("failed to delete test bucket");
     }

src/storage/s3/test.rs

@@ -0,0 +1,4 @@
+   Compiling tokio v0.2.21
+   Compiling cratesfyi v0.6.0 (G:\Users\Chase\Code\Rust\docs.rs)
+   Compiling tokio-util v0.3.1
+   Compiling tokio-tls v0.3.1