Changed error

crates/cdk-common/src/pub_sub/error.rs

@@ -5,10 +5,6 @@ use tokio::sync::mpsc::error::TrySendError;
 #[derive(thiserror::Error, Debug)]
 /// Error
 pub enum Error {
-    /// Already subscribed
-    #[error("Already subscribed")]
-    AlreadySubscribed,
-
     /// No subscription found
     #[error("Subscription not found")]
     NoSubscription,

crates/cdk-common/src/pub_sub/remote_consumer.rs

@@ -278,7 +278,7 @@ where
             .subscriptions
             .write()
             .remove(&subscription_name)
-            .ok_or(Error::AlreadySubscribed)?;
+            .ok_or(Error::NoSubscription)?;
 
         let mut remote_subscriptions = self.remote_subscriptions.write();
 
@@ -348,7 +348,7 @@ where
         let mut subscriptions = self.subscriptions.write();
 
         if subscriptions.get(&subscription_name).is_some() {
-            return Err(Error::AlreadySubscribed);
+            return Err(Error::NoSubscription);
         }
 
         let mut previous_messages = Vec::new();