fix deprecated UnboundedSender::send() to unbounded_send()
This commit is contained in:
@@ -11,7 +11,7 @@ categories = ["web-programming::http-client"]
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
bytes = "0.4"
|
bytes = "0.4"
|
||||||
futures = "0.1.14"
|
futures = "0.1.15"
|
||||||
hyper = "0.11"
|
hyper = "0.11"
|
||||||
hyper-tls = "0.1.2"
|
hyper-tls = "0.1.2"
|
||||||
libflate = "0.1.11"
|
libflate = "0.1.11"
|
||||||
|
|||||||
@@ -387,7 +387,11 @@ impl ClientHandle {
|
|||||||
let (tx, rx) = oneshot::channel();
|
let (tx, rx) = oneshot::channel();
|
||||||
let (req, body) = request::async(req);
|
let (req, body) = request::async(req);
|
||||||
let url = req.url().clone();
|
let url = req.url().clone();
|
||||||
self.inner.tx.as_ref().expect("core thread exited early").send((req, tx)).expect("core thread panicked");
|
self.inner.tx
|
||||||
|
.as_ref()
|
||||||
|
.expect("core thread exited early")
|
||||||
|
.unbounded_send((req, tx))
|
||||||
|
.expect("core thread panicked");
|
||||||
|
|
||||||
if let Some(body) = body {
|
if let Some(body) = body {
|
||||||
try_!(body.send(), &url);
|
try_!(body.send(), &url);
|
||||||
|
|||||||
Reference in New Issue
Block a user