1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41
use std::marker::PhantomData; use std::task::{Context, Poll}; use actix_codec::Framed; use actix_service::{Service, ServiceFactory}; use futures_util::future::Ready; use crate::error::Error; use crate::h1::Codec; use crate::request::Request; pub struct UpgradeHandler<T>(PhantomData<T>); impl<T> ServiceFactory for UpgradeHandler<T> { type Config = (); type Request = (Request, Framed<T, Codec>); type Response = (); type Error = Error; type Service = UpgradeHandler<T>; type InitError = Error; type Future = Ready<Result<Self::Service, Self::InitError>>; fn new_service(&self, _: ()) -> Self::Future { unimplemented!() } } impl<T> Service for UpgradeHandler<T> { type Request = (Request, Framed<T, Codec>); type Response = (); type Error = Error; type Future = Ready<Result<Self::Response, Self::Error>>; fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>> { Poll::Ready(Ok(())) } fn call(&mut self, _: Self::Request) -> Self::Future { unimplemented!() } }