1111
1212namespace Tests . ClientConcepts . Connection
1313{
14- public class HttpConnectionTests
15- {
16- public class TestableHttpConnection : HttpConnection
17- {
18- public int ClientCount => this . Clients . Count ;
19-
20- public int CallCount { get ; private set ; }
21-
22- public override ElasticsearchResponse < TReturn > Request < TReturn > ( RequestData requestData )
23- {
24- CallCount ++ ;
25- return base . Request < TReturn > ( requestData ) ;
26- }
27-
28- public override Task < ElasticsearchResponse < TReturn > > RequestAsync < TReturn > ( RequestData requestData )
29- {
30- CallCount ++ ;
31- return base . RequestAsync < TReturn > ( requestData ) ;
32- }
33- }
34-
35- [ U ]
36- public async Task SingleInstanceOfHttpClient ( )
37- {
14+ public class HttpConnectionTests
15+ {
16+ public class TestableHttpConnection : HttpConnection
17+ {
18+ public int ClientCount => this . Clients . Count ;
19+
20+ public int CallCount { get ; private set ; }
21+
22+ public override ElasticsearchResponse < TReturn > Request < TReturn > ( RequestData requestData )
23+ {
24+ CallCount ++ ;
25+ return base . Request < TReturn > ( requestData ) ;
26+ }
27+
28+ public override Task < ElasticsearchResponse < TReturn > > RequestAsync < TReturn > ( RequestData requestData )
29+ {
30+ CallCount ++ ;
31+ return base . RequestAsync < TReturn > ( requestData ) ;
32+ }
33+ }
34+
35+ [ U ]
36+ public async Task SingleInstanceOfHttpClient ( )
37+ {
3838 var connection = new TestableHttpConnection ( ) ;
39- var requestData = CreateRequestData ( TimeSpan . FromMinutes ( 1 ) ) ;
39+ var requestData = CreateRequestData ( TimeSpan . FromMinutes ( 1 ) ) ;
4040 connection . Request < string > ( requestData ) ;
4141
4242 connection . CallCount . Should ( ) . Be ( 1 ) ;
43- connection . ClientCount . Should ( ) . Be ( 1 ) ;
43+ connection . ClientCount . Should ( ) . Be ( 1 ) ;
4444
4545 await connection . RequestAsync < string > ( requestData ) . ConfigureAwait ( false ) ;
4646
4747 connection . CallCount . Should ( ) . Be ( 2 ) ;
4848 connection . ClientCount . Should ( ) . Be ( 1 ) ;
4949 }
5050
51- [ U ]
51+ [ U ]
5252 public async Task MultipleInstancesOfHttpClientWhenRequestTimeoutChanges ( )
5353 {
5454 await MultipleInstancesOfHttpClientWhen ( ( ) => CreateRequestData ( TimeSpan . FromSeconds ( 30 ) ) ) ;
@@ -72,23 +72,23 @@ public async Task MultipleInstancesOfHttpClientWhenHttpCompressionChanges()
7272 await MultipleInstancesOfHttpClientWhen ( ( ) => CreateRequestData ( httpCompression : true ) ) ;
7373 }
7474
75- private static async Task MultipleInstancesOfHttpClientWhen ( Func < RequestData > differentRequestData )
76- {
77- var connection = new TestableHttpConnection ( ) ;
78- var requestData = CreateRequestData ( ) ;
79- connection . Request < string > ( requestData ) ;
75+ private static async Task MultipleInstancesOfHttpClientWhen ( Func < RequestData > differentRequestData )
76+ {
77+ var connection = new TestableHttpConnection ( ) ;
78+ var requestData = CreateRequestData ( ) ;
79+ connection . Request < string > ( requestData ) ;
8080
81- connection . CallCount . Should ( ) . Be ( 1 ) ;
82- connection . ClientCount . Should ( ) . Be ( 1 ) ;
81+ connection . CallCount . Should ( ) . Be ( 1 ) ;
82+ connection . ClientCount . Should ( ) . Be ( 1 ) ;
8383
84- requestData = differentRequestData ( ) ;
85- await connection . RequestAsync < string > ( requestData ) . ConfigureAwait ( false ) ;
84+ requestData = differentRequestData ( ) ;
85+ await connection . RequestAsync < string > ( requestData ) . ConfigureAwait ( false ) ;
8686
87- connection . CallCount . Should ( ) . Be ( 2 ) ;
88- connection . ClientCount . Should ( ) . Be ( 2 ) ;
89- }
87+ connection . CallCount . Should ( ) . Be ( 2 ) ;
88+ connection . ClientCount . Should ( ) . Be ( 2 ) ;
89+ }
9090
91- private static RequestData CreateRequestData (
91+ private static RequestData CreateRequestData (
9292 TimeSpan requestTimeout = default ( TimeSpan ) ,
9393 Uri proxyAddress = null ,
9494 bool disableAutomaticProxyDetection = false ,
@@ -106,12 +106,12 @@ private static RequestData CreateRequestData(
106106 connectionSettings . Proxy ( proxyAddress , null , null ) ;
107107
108108 var requestData = new RequestData ( HttpMethod . GET , "/" , null , connectionSettings , new PingRequestParameters ( ) ,
109- new MemoryStreamFactory ( ) )
110- {
111- Node = new Node ( new Uri ( "http://localhost:9200" ) )
112- } ;
113- return requestData ;
114- }
115- }
109+ new MemoryStreamFactory ( ) )
110+ {
111+ Node = new Node ( new Uri ( "http://localhost:9200" ) )
112+ } ;
113+ return requestData ;
114+ }
115+ }
116116}
117117#endif
0 commit comments