@@ -144,16 +144,14 @@ where
144
144
145
145
struct InnerRpcRequest < T , F > {
146
146
transport_future : F ,
147
- method : String ,
148
147
id : Id ,
149
148
_marker : :: std:: marker:: PhantomData < T > ,
150
149
}
151
150
152
151
impl < T , F > InnerRpcRequest < T , F > {
153
- fn new ( transport_future : F , method : String , id : Id ) -> Self {
152
+ fn new ( transport_future : F , id : Id ) -> Self {
154
153
Self {
155
154
transport_future,
156
- method,
157
155
id,
158
156
_marker : :: std:: marker:: PhantomData ,
159
157
}
@@ -176,9 +174,8 @@ where
176
174
. chain_err( || ErrorKind :: TransportError )
177
175
) ;
178
176
trace ! (
179
- "Deserializing {} byte response to method \" {} \" with id {:?}" ,
177
+ "Deserializing {} byte response to request with id {:?}" ,
180
178
response_raw. len( ) ,
181
- self . method,
182
179
self . id
183
180
) ;
184
181
response:: parse ( & response_raw, & self . id ) . map ( |t| Async :: Ready ( t) )
@@ -224,13 +221,13 @@ where
224
221
{
225
222
let id = Id :: Num ( transport. get_next_id ( ) ) ;
226
223
trace ! ( "Serializing call to method \" {}\" with id {:?}" , method, id) ;
227
- let request_serialization_result = serialize_request ( id. clone ( ) , method. clone ( ) , params)
224
+ let request_serialization_result = serialize_request ( id. clone ( ) , method, params)
228
225
. chain_err ( || ErrorKind :: SerializeError ) ;
229
226
match request_serialization_result {
230
227
Err ( e) => RpcRequest ( Err ( Some ( e) ) ) ,
231
228
Ok ( request_raw) => {
232
229
let transport_future = transport. send ( request_raw) ;
233
- RpcRequest ( Ok ( InnerRpcRequest :: new ( transport_future, method , id) ) )
230
+ RpcRequest ( Ok ( InnerRpcRequest :: new ( transport_future, id) ) )
234
231
}
235
232
}
236
233
}
0 commit comments