1
1
//! HTTP Transport
2
2
3
- use crate :: error:: RateLimit ;
4
3
use crate :: {
5
- error:: { Error , Result , TransportError } ,
4
+ error:: { Error , RateLimit , Result , TransportError } ,
6
5
helpers, BatchTransport , RequestId , Transport ,
7
6
} ;
8
7
use async_recursion:: async_recursion;
@@ -14,8 +13,7 @@ use futures::future::BoxFuture;
14
13
use futures:: future:: LocalBoxFuture as BoxFuture ;
15
14
use futures_timer:: Delay ;
16
15
use jsonrpc_core:: types:: { Call , Output , Request , Value } ;
17
- use reqwest:: header:: HeaderMap ;
18
- use reqwest:: { Client , Url } ;
16
+ use reqwest:: { header:: HeaderMap , Client , Url } ;
19
17
use serde:: de:: DeserializeOwned ;
20
18
use std:: {
21
19
collections:: HashMap ,
@@ -310,15 +308,15 @@ mod tests {
310
308
use super :: * ;
311
309
use crate :: Error :: Rpc ;
312
310
use core:: pin:: Pin ;
313
- use futures:: lock:: Mutex ;
314
- use futures:: Future ;
315
- use hyper:: body:: HttpBody ;
316
- use hyper:: service:: { make_service_fn, service_fn} ;
317
- use hyper:: { Body , Error , Method , Request , Response , Server } ;
311
+ use futures:: { lock:: Mutex , Future } ;
312
+ use hyper:: {
313
+ body:: HttpBody ,
314
+ service:: { make_service_fn, service_fn} ,
315
+ Body , Error , Method , Request , Response , Server ,
316
+ } ;
318
317
use jsonrpc_core:: ErrorCode ;
319
318
use std:: net:: TcpListener ;
320
- use tokio:: task:: JoinHandle ;
321
- use tokio:: time:: Instant ;
319
+ use tokio:: { task:: JoinHandle , time:: Instant } ;
322
320
323
321
type HyperResponse = Pin < Box < dyn Future < Output = hyper:: Result < Response < Body > > > + Send > > ;
324
322
0 commit comments