Skip to content

Commit 804c967

Browse files
committed
formatting changes
1 parent 9398a7e commit 804c967

File tree

2 files changed

+37
-36
lines changed

2 files changed

+37
-36
lines changed

src/Nest/Domain/Connection/Connection.cs

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -75,13 +75,14 @@ public Task<ConnectionStatus> Post(string path, string data)
7575
{
7676
var r = this.CreateConnection(path, "POST");
7777
return this.DoAsyncRequest(r, data);
78-
7978
}
79+
8080
public Task<ConnectionStatus> Put(string path, string data)
8181
{
8282
var r = this.CreateConnection(path, "PUT");
8383
return this.DoAsyncRequest(r, data);
8484
}
85+
8586
public Task<ConnectionStatus> Delete(string path, string data)
8687
{
8788
var r = this.CreateConnection(path, "DELETE");
@@ -146,14 +147,14 @@ private void SetBasicAuthorizationIfNeeded(HttpWebRequest myReq)
146147
if (myUri != null && !string.IsNullOrEmpty(myUri.UserInfo))
147148
{
148149
myReq.Headers["Authorization"] =
149-
"Basic " + Convert.ToBase64String(Encoding.UTF8.GetBytes(myUri.UserInfo));
150+
"Basic " + Convert.ToBase64String(Encoding.UTF8.GetBytes(myUri.UserInfo));
150151
}
151152
}
152153

153154
protected virtual HttpWebRequest CreateWebRequest(string path, string method)
154155
{
155156
var url = this._CreateUriString(path);
156-
157+
157158
HttpWebRequest myReq = (HttpWebRequest)WebRequest.Create(url);
158159
myReq.Accept = "application/json";
159160
myReq.ContentType = "application/json";
@@ -205,19 +206,19 @@ protected virtual ConnectionStatus DoSynchronousRequest(HttpWebRequest request,
205206
};
206207
tracer.SetResult(cs);
207208

208-
_ConnectionSettings.ConnectionStatusHandler(cs);
209+
_ConnectionSettings.ConnectionStatusHandler(cs);
209210

210211
return cs;
211212
}
212213
}
213-
214+
214215
}
215216

216217
protected virtual Task<ConnectionStatus> DoAsyncRequest(HttpWebRequest request, string data = null)
217218
{
218219
var tcs = new TaskCompletionSource<ConnectionStatus>();
219220
if (this._ConnectionSettings.MaximumAsyncConnections <= 0
220-
|| this._ResourceLock == null)
221+
|| this._ResourceLock == null)
221222
return this.CreateIterateTask(request, data, tcs);
222223

223224
var timeout = this._ConnectionSettings.Timeout;
@@ -226,7 +227,7 @@ protected virtual Task<ConnectionStatus> DoAsyncRequest(HttpWebRequest request,
226227
using (var tracer = new ConnectionStatusTracer(this._ConnectionSettings.TraceEnabled))
227228
{
228229
var m = "Could not start the operation before the timeout of " + timeout +
229-
"ms completed while waiting for the semaphore";
230+
"ms completed while waiting for the semaphore";
230231
var cs = new ConnectionStatus(this._ConnectionSettings, new TimeoutException(m));
231232
tcs.SetResult(cs);
232233
tracer.SetResult(cs);
@@ -338,9 +339,9 @@ public void Iterate(IEnumerable<Task> asyncIterator, TaskCompletionSource<Connec
338339

339340
private Uri _CreateUriString(string path)
340341
{
341-
var s = this._ConnectionSettings;
342-
343-
342+
var s = this._ConnectionSettings;
343+
344+
344345
if (s.QueryStringParameters != null)
345346
{
346347
var tempUri = new Uri(s.Uri, path);
@@ -349,7 +350,7 @@ private Uri _CreateUriString(string path)
349350
}
350351
path = this._ConnectionSettings.DontDoubleEscapePathDotsAndSlashes ? path : path.Replace("%2F", "%252F");
351352
var uri = new Uri(s.Uri, path);
352-
353+
353354
//WebRequest.Create will replace %2F with /
354355
//this is a 'security feature'
355356
//see http://mikehadlow.blogspot.nl/2011/08/how-to-stop-systemuri-un-escaping.html
Lines changed: 25 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,26 @@
11
using System;
2-
using System.Threading.Tasks;
3-
4-
namespace Nest
5-
{
6-
public interface IConnection
7-
{
8-
Task<ConnectionStatus> Get(string path);
9-
ConnectionStatus GetSync(string path);
10-
11-
Task<ConnectionStatus> Head(string path);
12-
ConnectionStatus HeadSync(string path);
13-
14-
Task<ConnectionStatus> Post(string path, string data);
15-
ConnectionStatus PostSync(string path, string data);
16-
17-
Task<ConnectionStatus> Put(string path, string data);
18-
ConnectionStatus PutSync(string path, string data);
19-
20-
Task<ConnectionStatus> Delete(string path);
21-
ConnectionStatus DeleteSync(string path);
22-
23-
Task<ConnectionStatus> Delete(string path, string data);
24-
ConnectionStatus DeleteSync(string path, string data);
25-
}
26-
}
2+
using System.Threading.Tasks;
3+
4+
namespace Nest
5+
{
6+
public interface IConnection
7+
{
8+
Task<ConnectionStatus> Get(string path);
9+
ConnectionStatus GetSync(string path);
10+
11+
Task<ConnectionStatus> Head(string path);
12+
ConnectionStatus HeadSync(string path);
13+
14+
Task<ConnectionStatus> Post(string path, string data);
15+
ConnectionStatus PostSync(string path, string data);
16+
17+
Task<ConnectionStatus> Put(string path, string data);
18+
ConnectionStatus PutSync(string path, string data);
19+
20+
Task<ConnectionStatus> Delete(string path);
21+
ConnectionStatus DeleteSync(string path);
22+
23+
Task<ConnectionStatus> Delete(string path, string data);
24+
ConnectionStatus DeleteSync(string path, string data);
25+
}
26+
}

0 commit comments

Comments
 (0)