Added formatting

Author: rakshith-ravi

src/connection/base_connection.rs

@@ -1,4 +1,4 @@
-use crate::{connection::Buffer, utils::Error, juno_module_impl::JunoModuleImpl};
+use crate::{connection::Buffer, juno_module_impl::JunoModuleImpl, utils::Error};
 use async_trait::async_trait;
 use std::sync::Arc;
 
@@ -7,7 +7,7 @@ pub trait BaseConnection {
 	async fn setup_connection(&mut self) -> Result<(), Error>;
 	async fn close_connection(&mut self) -> Result<(), Error>;
 	async fn send(&mut self, buffer: Buffer) -> Result<(), Error>;
-	
+
 	fn set_data_listener(&mut self, listener: Arc<JunoModuleImpl>);
 	fn get_data_listener(&self) -> &Option<Arc<JunoModuleImpl>>;
 }

src/connection/inet_socket_connection.rs

@@ -7,13 +7,12 @@ use std::sync::Arc;
 
 use async_std::{io::BufReader, net::TcpStream, prelude::*, task};
 use async_trait::async_trait;
-use future::Either;
 use futures::{
 	channel::{
 		mpsc::{unbounded, UnboundedReceiver, UnboundedSender},
 		oneshot::{channel, Sender},
 	},
-	future, SinkExt,
+	future::{self, Either}, SinkExt,
 };
 
 pub struct InetSocketConnection {
@@ -97,13 +96,13 @@ impl BaseConnection for InetSocketConnection {
 }
 
 async fn read_data_from_socket(
-	socket_path: String,
+	connect_addr: String,
 	init_sender: Sender<Result<(), Error>>,
 	juno_impl: Arc<JunoModuleImpl>,
 	mut write_receiver: UnboundedReceiver<Vec<u8>>,
 	mut close_receiver: UnboundedReceiver<()>,
 ) {
-	let result = TcpStream::connect(socket_path).await;
+	let result = TcpStream::connect(connect_addr).await;
 	if let Err(err) = result {
 		init_sender
 			.send(Err(Error::Internal(format!("{}", err))))

src/connection/unix_socket_connection.rs

@@ -7,13 +7,12 @@ use std::sync::Arc;
 
 use async_std::{io::BufReader, os::unix::net::UnixStream, prelude::*, task};
 use async_trait::async_trait;
-use future::Either;
 use futures::{
 	channel::{
 		mpsc::{unbounded, UnboundedReceiver, UnboundedSender},
 		oneshot::{channel, Sender},
 	},
-	future, SinkExt,
+	future::{self, Either}, SinkExt,
 };
 
 pub struct UnixSocketConnection {