Skip to content

Commit de1b43e

Browse files
committed
update redis code for latest library version
1 parent eac9b33 commit de1b43e

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

Cargo.lock

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/redis.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,7 @@ async fn subscribe_inner(
4444
stats: &'static RedisStats,
4545
) -> Result<(), RedisError> {
4646
log::info!("Redis stream connecting ...");
47-
let con = client.get_tokio_connection().await?;
48-
let mut pubsub = con.into_pubsub();
47+
let mut pubsub = client.get_async_pubsub().await?;
4948
pubsub.subscribe("http-out").await?;
5049
let mut stream = pubsub.on_message();
5150
log::info!("Redis stream connected.");

0 commit comments

Comments
 (0)