diff --git a/src/client.rs b/src/client.rs index 2ec9992..81cbd38 100644 --- a/src/client.rs +++ b/src/client.rs @@ -49,7 +49,7 @@ macro_rules! impl_inner_call { drop(read_client); match res { Ok(val) => return Ok(val), - Err(Error::Protocol(_)) => { + Err(Error::Protocol(_) | Error::AlreadySubscribed(_)) => { return res; }, Err(e) => {