use futures_util::{stream::StreamExt, Sink, SinkExt, Stream};
-use jsonrpsee::core::{
- async_trait,
- client::{ReceivedMessage, TransportReceiverT, TransportSenderT},
-};
+use jsonrpsee::core::client::{ReceivedMessage, TransportReceiverT, TransportSenderT};
use thiserror::Error;
pub mod ipc;
inner: T,
}
-#[async_trait]
impl<T: Send + Sink<String, Error = impl std::error::Error> + Unpin + 'static> TransportSenderT
for Sender<T>
{
self.inner
.send(body)
.await
- .map_err(|e| Errors::Other(format!("{:?}", e)))?;
+ .map_err(|e| Errors::Other(format!("{e:?}")))?;
Ok(())
}
self.inner
.close()
.await
- .map_err(|e| Errors::Other(format!("{:?}", e)))?;
+ .map_err(|e| Errors::Other(format!("{e:?}")))?;
Ok(())
}
}
inner: T,
}
-#[async_trait]
impl<T: Send + Stream<Item = Result<String, std::io::Error>> + Unpin + 'static> TransportReceiverT
for Receiver<T>
{
match self.inner.next().await {
None => Err(Errors::Closed),
Some(Ok(msg)) => Ok(ReceivedMessage::Text(msg)),
- Some(Err(e)) => Err(Errors::Other(format!("{:?}", e))),
+ Some(Err(e)) => Err(Errors::Other(format!("{e:?}"))),
}
}
}