actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2025-01-22 23:05:56 +01:00
Code Issues Releases Wiki Activity

Update actix-redis to current state (beta) of actix (#210)

Browse Source
This commit is contained in:
Sergey Pashinin 2021-12-06 04:03:18 +03:00 committed by GitHub
parent 64acd3229f
commit e636af039a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
actix-redis/Cargo.toml
View File

@ -32,7 +32,7 @@ web = [
actix = { version = "0.12.0", default-features = false } actix = { version = "0.12.0", default-features = false }
actix-rt = { version = "2.1", default-features = false } actix-rt = { version = "2.1", default-features = false }
actix-service = "2.0.0" actix-service = "2.0.0"
actix-tls = { version = "3.0.0-beta.7", default-features = false, features = ["connect"] } actix-tls = { version = "3.0.0-rc.1", default-features = false, features = ["connect"] }
log = "0.4.6" log = "0.4.6"
backoff = "0.2.1" backoff = "0.2.1"

4
actix-redis/src/redis.rs
View File

@ -4,7 +4,7 @@ use std::io;
use actix::prelude::*; use actix::prelude::*;
use actix_rt::net::TcpStream; use actix_rt::net::TcpStream;
use actix_service::boxed::{service, BoxService}; use actix_service::boxed::{service, BoxService};
use actix_tls::connect::{default_connector, Connect, ConnectError, Connection}; use actix_tls::connect::{ConnectError, ConnectInfo as Connect, Connection, Connector};
use backoff::backoff::Backoff; use backoff::backoff::Backoff;
use backoff::ExponentialBackoff; use backoff::ExponentialBackoff;
use log::{error, info, warn}; use log::{error, info, warn};
@ -45,7 +45,7 @@ impl RedisActor {
Supervisor::start(|_| RedisActor { Supervisor::start(|_| RedisActor {
addr, addr,
connector: service(default_connector()), connector: service(Connector::default().service()),
cell: None, cell: None,
backoff, backoff,
queue: VecDeque::new(), queue: VecDeque::new(),