berkus
/
actix-web
mirror of https://github.com/fafhrd91/actix-web
1
0
Fork 0
Code Issues Releases Wiki Activity

static error handler middleware future

This commit is contained in:
ibraheemdev 2021-04-22 12:15:37 -04:00
parent 015e1c7b4d
commit aacb461bfb
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/middleware/condition.rs
View File

@ -6,7 +6,6 @@ use std::task::{Context, Poll};
use actix_service::{Service, Transform}; use actix_service::{Service, Transform};
use actix_utils::future::Either; use actix_utils::future::Either;
use futures_core::ready; use futures_core::ready;
/// Middleware for conditionally enabling other middleware. /// Middleware for conditionally enabling other middleware.

9
src/middleware/err_handlers.rs
View File

@ -9,7 +9,10 @@ use std::{
use actix_service::{Service, Transform}; use actix_service::{Service, Transform};
use ahash::AHashMap; use ahash::AHashMap;
use futures_core::{future::LocalBoxFuture, ready}; use futures_util::{
future::{ok, LocalBoxFuture, Ready},
ready,
};
use crate::{ use crate::{
dev::{ServiceRequest, ServiceResponse}, dev::{ServiceRequest, ServiceResponse},
@ -97,11 +100,11 @@ where
type Error = Error; type Error = Error;
type Transform = ErrorHandlersMiddleware<S, B>; type Transform = ErrorHandlersMiddleware<S, B>;
type InitError = (); type InitError = ();
type Future = LocalBoxFuture<'static, Result<Self::Transform, Self::InitError>>; type Future = Ready<Result<Self::Transform, Self::InitError>>;
fn new_transform(&self, service: S) -> Self::Future { fn new_transform(&self, service: S) -> Self::Future {
let handlers = self.handlers.clone(); let handlers = self.handlers.clone();
Box::pin(async move { Ok(ErrorHandlersMiddleware { service, handlers }) }) ok(ErrorHandlersMiddleware { service, handlers })
} }
} }