adding Send and Sync to SubscriptionSink

core/src/subscription_handler.rs

@@ -9,7 +9,7 @@ use tokio::time::Instant;
 
 use crate::{block_processor::TransactionInfo, subscription_sink::SubscriptionSink};
 
-pub type SubscptionHanderSink = Arc<dyn SubscriptionSink + Sync + Send>;
+pub type SubscptionHanderSink = Arc<dyn SubscriptionSink>;
 
 #[derive(Clone, Default)]
 pub struct SubscriptionHandler {

core/src/subscription_sink.rs

@@ -2,7 +2,7 @@ use async_trait::async_trait;
 use solana_sdk::slot_history::Slot;
 
 #[async_trait]
-pub trait SubscriptionSink {
+pub trait SubscriptionSink: Send + Sync {
     async fn send(&self, slot: Slot, message: serde_json::Value);
     fn is_closed(&self) -> bool;
 }

lite-rpc/src/jsonrpsee_subscrption_handler_sink.rs

@@ -36,7 +36,3 @@ impl solana_lite_rpc_core::subscription_sink::SubscriptionSink
         self.jsonrpsee_sink.is_closed()
     }
 }
-
-unsafe impl Send for JsonRpseeSubscriptionHandlerSink {}
-
-unsafe impl Sync for JsonRpseeSubscriptionHandlerSink {}