@@ -14,14 +14,14 @@ impl UdpRequest {
1414 & mut self ,
1515 socket : & mut UdpSocket ,
1616 data : & [ u8 ] ,
17- ) -> Result < BoxResponseTrait , Error > {
17+ ) -> Result < BoxResponseTrait , RequestError > {
1818 socket
1919 . send ( data)
20- . map_err ( |err| Error :: SendResponseError ( err. to_string ( ) ) ) ?;
20+ . map_err ( |err| RequestError :: SendResponseError ( err. to_string ( ) ) ) ?;
2121 self . read_response ( socket)
2222 }
2323
24- fn read_response ( & mut self , socket : & mut UdpSocket ) -> Result < BoxResponseTrait , Error > {
24+ fn read_response ( & mut self , socket : & mut UdpSocket ) -> Result < BoxResponseTrait , RequestError > {
2525 let cfg_buffer_size: usize = self
2626 . get_config ( )
2727 . read ( )
@@ -39,25 +39,25 @@ impl UdpRequest {
3939 ) ) ;
4040 }
4141
42- fn get_connection_socket ( & self , host : String , port : usize ) -> Result < UdpSocket , Error > {
42+ fn get_connection_socket ( & self , host : String , port : usize ) -> Result < UdpSocket , RequestError > {
4343 let host_port: String = format ! ( "{}:{}" , host. clone( ) , port) ;
4444 let cfg_timeout: u64 = self
4545 . get_config ( )
4646 . read ( )
4747 . map_or ( DEFAULT_TIMEOUT , |data| data. timeout ) ;
4848 let timeout: Duration = Duration :: from_millis ( cfg_timeout) ;
4949 let socket: UdpSocket =
50- UdpSocket :: bind ( "0.0.0.0:0" ) . map_err ( |_| Error :: UdpSocketCreateError ) ?;
50+ UdpSocket :: bind ( "0.0.0.0:0" ) . map_err ( |_| RequestError :: UdpSocketCreateError ) ?;
5151 socket
5252 . connect ( host_port)
53- . map_err ( |_| Error :: UdpSocketConnectError ) ?;
53+ . map_err ( |_| RequestError :: UdpSocketConnectError ) ?;
5454 socket
5555 . set_read_timeout ( Some ( timeout) )
56- . map_err ( |_| Error :: SetReadTimeoutError ) ?;
56+ . map_err ( |_| RequestError :: SetReadTimeoutError ) ?;
5757 socket
5858 . set_write_timeout ( Some ( timeout) )
59- . map_err ( |_| Error :: SetWriteTimeoutError ) ?;
60- let socket_result: Result < UdpSocket , Error > = Ok ( socket) ;
59+ . map_err ( |_| RequestError :: SetWriteTimeoutError ) ?;
60+ let socket_result: Result < UdpSocket , RequestError > = Ok ( socket) ;
6161 socket_result
6262 }
6363}
@@ -73,7 +73,7 @@ impl RequestTrait for UdpRequest {
7373 let host: String = cfg_timeout. get_host ( ) . clone ( ) ;
7474 let port: usize = cfg_timeout. get_port ( ) . clone ( ) ;
7575 let mut socket: UdpSocket = self . get_connection_socket ( host, port) ?;
76- let res: Result < BoxResponseTrait , Error > = self . send_request ( & mut socket, data) ;
76+ let res: Result < BoxResponseTrait , RequestError > = self . send_request ( & mut socket, data) ;
7777 res
7878 }
7979}
0 commit comments