remove twrite

Author: Migorithm

duva/src/adapters/io/tokio_stream.rs

@@ -1,4 +1,4 @@
-use crate::domains::interface::{TRead, TWrite};
+use crate::domains::interface::TRead;
 use crate::domains::peers::command::*;
 use crate::domains::peers::connections::connection_types::{ReadConnected, WriteConnected};
 use crate::domains::query_io::SERDE_CONFIG;
@@ -16,13 +16,6 @@ use tokio::net::TcpStream;
 const BUFFER_SIZE: usize = 512;
 const INITIAL_CAPACITY: usize = 1024;
 
-#[async_trait::async_trait]
-impl<T: AsyncWriteExt + std::marker::Unpin + Sync + Send + Debug + 'static> TWrite for T {
-    async fn write(&mut self, io: QueryIO) -> Result<(), IoError> {
-        self.write_all(&io.serialize()).await.map_err(|e| io_error_from_kind(e.kind()))
-    }
-}
-
 #[async_trait::async_trait]
 impl<T: AsyncReadExt + std::marker::Unpin + Sync + Send + Debug + 'static> TReadBytes for T {
     // TCP doesn't inherently delimit messages.

duva/src/domains/cluster_actors/actor/tests/mod.rs

@@ -24,7 +24,7 @@ use crate::domains::peers::connections::inbound::stream::InboundStream;
 use crate::domains::peers::service::PeerListener;
 use crate::types::Callback;
 use crate::{
-    domains::{IoError, TRead, TWrite},
+    domains::{IoError, TRead},
     make_smart_pointer,
 };
 use std::collections::VecDeque;
@@ -47,12 +47,6 @@ impl FakeReadWrite {
         Self(Arc::new(Mutex::new(VecDeque::new())))
     }
 }
-#[async_trait::async_trait]
-impl TWrite for FakeReadWrite {
-    async fn write(&mut self, _io: QueryIO) -> Result<(), IoError> {
-        panic!()
-    }
-}
 
 #[async_trait::async_trait]
 impl TSerdeDynamicRead for FakeReadWrite {

duva/src/domains/interface.rs

@@ -26,16 +26,11 @@ pub(crate) trait TSerdeDynamicRead: TRead + Send + Sync + Debug + 'static {
 }
 
 #[async_trait::async_trait]
-pub(crate) trait TSerdeDynamicWrite: TWrite + Send + Sync + Debug + 'static {
+pub(crate) trait TSerdeDynamicWrite: Send + Sync + Debug + 'static {
     async fn send(&mut self, msg: PeerMessage) -> Result<(), IoError>;
     async fn send_connection_msg(&mut self, arg: &str) -> Result<(), IoError>;
 }
 
-#[async_trait::async_trait]
-pub(crate) trait TWrite: Send + Sync + Debug + 'static {
-    async fn write(&mut self, io: QueryIO) -> Result<(), IoError>;
-}
-
 pub trait TSerdeWrite {
     fn serialized_write(
         &mut self,