rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-11-02 12:06:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(router): subscriber return type (#1292)

Browse Source
This commit is contained in:
Kartikeya Hegde
2023-05-31 13:13:55 +05:30
committed by GitHub
parent fa392c40a8
commit 55bb117e1d
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/router/src/services.rs
View File

@ -23,10 +23,7 @@ use crate::{
#[async_trait::async_trait]
pub trait PubSubInterface {
async fn subscribe(
&self,
channel: &str,
) -> errors::CustomResult<usize, redis_errors::RedisError>;
async fn subscribe(&self, channel: &str) -> errors::CustomResult<(), redis_errors::RedisError>;
async fn publish<'a>(
&self,
@ -40,10 +37,7 @@ pub trait PubSubInterface {
#[async_trait::async_trait]
impl PubSubInterface for redis_interface::RedisConnectionPool {
#[inline]
async fn subscribe(
&self,
channel: &str,
) -> errors::CustomResult<usize, redis_errors::RedisError> {
async fn subscribe(&self, channel: &str) -> errors::CustomResult<(), redis_errors::RedisError> {
// Spawns a task that will automatically re-subscribe to any channels or channel patterns used by the client.
self.subscriber.manage_subscriptions();