updated to tokio 1.0 (#158)

Author: krojew

elasticsearch/Cargo.toml

@@ -23,10 +23,10 @@ rustls-tls = ["reqwest/rustls-tls"]
 
 [dependencies]
 base64 = "^0.11"
-bytes = "^0.5"
+bytes = "^1.0"
 dyn-clone = "~1"
 percent-encoding = "2.1.0"
-reqwest = { version = "~0.10", default-features = false, features = ["gzip", "json"] }
+reqwest = { version = "~0.11", default-features = false, features = ["gzip", "json"] }
 url = "^2.1"
 serde = { version = "~1", features = ["derive"] }
 serde_json = "~1"
@@ -39,12 +39,12 @@ clap = "~2"
 failure = "0.1.5"
 futures = "0.3.1"
 http = "0.2"
-hyper = { version = "0.13", default-features = false, features = ["tcp", "stream"] }
+hyper = { version = "0.14", default-features = false, features = ["tcp", "stream", "server"] }
 os_type = "2.2"
 sysinfo = "0.12.0"
 textwrap = "^0.11"
-tokio = { version = "0.2.0", default-features = false, features = ["macros", "tcp", "time"] }
+tokio = { version = "1.0", default-features = false, features = ["macros", "net", "time", "rt-multi-thread"] }
 xml-rs = "^0.8"
 
 [build-dependencies]
-rustc_version = "0.2"
+rustc_version = "0.2"

elasticsearch/src/http/request.rs

@@ -19,7 +19,7 @@
 //! HTTP request components
 
 use crate::error::Error;
-use bytes::{buf::BufMutExt, BufMut, Bytes, BytesMut};
+use bytes::{BufMut, Bytes, BytesMut};
 use percent_encoding::AsciiSet;
 use serde::Serialize;
 

elasticsearch/src/root/bulk.rs

@@ -21,7 +21,7 @@ use crate::{
     params::{SourceFilter, VersionType},
     Error,
 };
-use bytes::{buf::BufMutExt, BufMut, Bytes, BytesMut};
+use bytes::{BufMut, Bytes, BytesMut};
 use serde::{
     ser::{SerializeMap, Serializer},
     Deserialize, Serialize,

elasticsearch/tests/common/server.rs

@@ -62,8 +62,7 @@ where
 {
     //Spawn new runtime in thread to prevent reactor execution context conflict
     thread::spawn(move || {
-        let mut rt = runtime::Builder::new()
-            .basic_scheduler()
+        let rt = runtime::Builder::new_current_thread()
             .enable_all()
             .build()
             .expect("new rt");

yaml_test_runner/Cargo.toml

@@ -38,4 +38,4 @@ flate2 = "~1"
 globset = "~0.4"
 
 [dev-dependencies]
-tokio = { version = "0.2.0", default-features = false, features = ["macros", "tcp", "time"] }
+tokio = { version = "1.0", default-features = false, features = ["macros", "net", "time"] }