mirror of
https://github.com/actix/actix-extras.git
synced 2025-07-01 12:15:08 +02:00
update deps
This commit is contained in:
@ -102,7 +102,8 @@ pub(crate) trait MessageType: Sized {
|
||||
}
|
||||
// connection keep-alive state
|
||||
header::CONNECTION => {
|
||||
ka = if let Ok(conn) = value.to_str().map(|conn| conn.trim()) {
|
||||
ka = if let Ok(conn) = value.to_str().map(|conn| conn.trim())
|
||||
{
|
||||
if conn.eq_ignore_ascii_case("keep-alive") {
|
||||
Some(ConnectionType::KeepAlive)
|
||||
} else if conn.eq_ignore_ascii_case("close") {
|
||||
@ -925,7 +926,6 @@ mod tests {
|
||||
let req = parse_ready!(&mut buf);
|
||||
|
||||
assert_eq!(req.inner().head.ctype, Some(ConnectionType::KeepAlive));
|
||||
|
||||
}
|
||||
|
||||
#[test]
|
||||
@ -986,7 +986,6 @@ mod tests {
|
||||
|
||||
assert!(req.upgrade());
|
||||
assert_eq!(req.inner().head.ctype, Some(ConnectionType::Upgrade));
|
||||
|
||||
}
|
||||
|
||||
#[test]
|
||||
|
@ -7,7 +7,7 @@ use super::{Codec, Frame, Message};
|
||||
|
||||
pub struct Transport<S, T>
|
||||
where
|
||||
S: Service<Frame, Response = Message>,
|
||||
S: Service<Frame, Response = Message> + 'static,
|
||||
T: AsyncRead + AsyncWrite,
|
||||
{
|
||||
inner: FramedTransport<S, T, Codec>,
|
||||
|
Reference in New Issue
Block a user