mirror of https://github.com/fafhrd91/actix-net
update tokio-native-tls
This commit is contained in:
parent
e4359f7589
commit
36e4fb44e8
|
@ -53,7 +53,7 @@ webpki-roots = { version = "0.20", optional = true }
|
||||||
|
|
||||||
# native-tls
|
# native-tls
|
||||||
native-tls = { version = "0.2", optional = true }
|
native-tls = { version = "0.2", optional = true }
|
||||||
tokio-native-tls = { version = "0.2.0", optional = true }
|
tokio-native-tls = { version = "0.3.0", optional = true }
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
bytes = "1"
|
bytes = "1"
|
||||||
|
|
|
@ -115,6 +115,8 @@ impl<T: AsyncRead + AsyncWrite + Unpin> Future for AcceptorServiceResponse<T> {
|
||||||
fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
|
fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
|
||||||
loop {
|
loop {
|
||||||
match self.as_mut().get_mut() {
|
match self.as_mut().get_mut() {
|
||||||
|
// Init branch only used to return the error in future
|
||||||
|
// on success goes to Accept branch directly.
|
||||||
AcceptorServiceResponse::Init(res, guard) => {
|
AcceptorServiceResponse::Init(res, guard) => {
|
||||||
let guard = guard.take();
|
let guard = guard.take();
|
||||||
let stream = res.take().unwrap()?;
|
let stream = res.take().unwrap()?;
|
||||||
|
|
Loading…
Reference in New Issue