forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(upgrade): allow http upgrades with any body type

Browse Source 
Allow using `Request<T>`/`Response<T>` for any given T with
`upgrade::on` instead of just restricting it to `hyper::Body`.
This commit is contained in:
Luqman Aden
2021-10-30 10:59:39 -07:00
committed by Sean McArthur
parent b5022f3854
commit ab469eb3c6
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/upgrade.rs
View File

@@ -258,7 +258,7 @@ mod sealed {
fn on_upgrade(self) -> OnUpgrade; fn on_upgrade(self) -> OnUpgrade;
} }
impl CanUpgrade for http::Request<crate::Body> { impl<B> CanUpgrade for http::Request<B> {
fn on_upgrade(mut self) -> OnUpgrade { fn on_upgrade(mut self) -> OnUpgrade {
self.extensions_mut() self.extensions_mut()
.remove::<OnUpgrade>() .remove::<OnUpgrade>()
@@ -266,7 +266,7 @@ mod sealed {
} }
} }
impl CanUpgrade for &'_ mut http::Request<crate::Body> { impl<B> CanUpgrade for &'_ mut http::Request<B> {
fn on_upgrade(self) -> OnUpgrade { fn on_upgrade(self) -> OnUpgrade {
self.extensions_mut() self.extensions_mut()
.remove::<OnUpgrade>() .remove::<OnUpgrade>()
@@ -274,7 +274,7 @@ mod sealed {
} }
} }
impl CanUpgrade for http::Response<crate::Body> { impl<B> CanUpgrade for http::Response<B> {
fn on_upgrade(mut self) -> OnUpgrade { fn on_upgrade(mut self) -> OnUpgrade {
self.extensions_mut() self.extensions_mut()
.remove::<OnUpgrade>() .remove::<OnUpgrade>()
@@ -282,7 +282,7 @@ mod sealed {
} }
} }
impl CanUpgrade for &'_ mut http::Response<crate::Body> { impl<B> CanUpgrade for &'_ mut http::Response<B> {
fn on_upgrade(self) -> OnUpgrade { fn on_upgrade(self) -> OnUpgrade {
self.extensions_mut() self.extensions_mut()
.remove::<OnUpgrade>() .remove::<OnUpgrade>()