actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2025-02-21 10:04:49 +01:00
Code Issues Releases Wiki Activity

update session impl

Browse Source
This commit is contained in:
Nikolay Kim 2018-01-10 16:51:09 -08:00
parent ae28b1ad81
commit abb6c6ba0a
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/session.rs
View File

@ -12,7 +12,7 @@ use redis_async::resp::RespValue;
use cookie::{CookieJar, Cookie, Key}; use cookie::{CookieJar, Cookie, Key};
use http::header::{self, HeaderValue}; use http::header::{self, HeaderValue};
use actix::prelude::*; use actix::prelude::*;
use actix_web::{error, Error, HttpRequest, HttpResponse}; use actix_web::{error, Error, Result, HttpRequest, HttpResponse};
use actix_web::middleware::{SessionImpl, SessionBackend, Response as MiddlewareResponse}; use actix_web::middleware::{SessionImpl, SessionBackend, Response as MiddlewareResponse};
use redis::{Command, RedisActor}; use redis::{Command, RedisActor};
@ -51,11 +51,12 @@ impl SessionImpl for RedisSession {
self.state.clear() self.state.clear()
} }
fn write(&self, resp: HttpResponse) -> MiddlewareResponse { fn write(&self, resp: HttpResponse) -> Result<MiddlewareResponse> {
if self.changed { if self.changed {
MiddlewareResponse::Future(self.inner.update(&self.state, resp, self.value.as_ref())) Ok(MiddlewareResponse::Future(
self.inner.update(&self.state, resp, self.value.as_ref())))
} else { } else {
MiddlewareResponse::Done(resp) Ok(MiddlewareResponse::Done(resp))
} }
} }
} }