Skip to content

Commit 027c333

Browse files
gmarzgmarz
committed
Merge pull request #1423 from elastic/feature/extensibility-enhancements
Feature/extensibility enhancements
2 parents c5e8510 + 7da7032 commit 027c333

File tree

67 files changed

+415
-441
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

67 files changed

+415
-441
lines changed

‎src/Elasticsearch.Net/Domain/Response/ElasticsearchResponse.cs‎

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,10 @@
1919

2020
namespace Elasticsearch.Net
2121
{
22-
//TODO document and possibly rename some of the properties
23-
22+
// TODO: Make this class internal in 2.0
2423
public static class ElasticsearchResponse
2524
{
26-
public static ElasticsearchResponse<TTo> CloneFrom<TTo>(IElasticsearchResponse from, TTo to)
25+
internal static ElasticsearchResponse<TTo> CloneFrom<TTo>(IElasticsearchResponse from, TTo to)
2726
{
2827
var response = new ElasticsearchResponse<TTo>(from.Settings)
2928
{
@@ -46,7 +45,6 @@ public static ElasticsearchResponse<TTo> CloneFrom<TTo>(IElasticsearchResponse f
4645
}
4746
}
4847

49-
5048
public class ElasticsearchResponse<T> : IElasticsearchResponse
5149
{
5250
private static readonly string _printFormat;

‎src/Nest/Domain/ICustomJson.cs‎

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,17 @@
22

33
namespace Nest
44
{
5-
//If an object implements this then it can handle its own json representation
5+
/// <summary>
6+
/// If an object implements this then it can handle its own json representation
7+
/// </summary>
68
public interface ICustomJson
79
{
810
object GetCustomJson();
911
}
1012

11-
public interface IDomainObject
12-
{
13-
14-
}
13+
/// <summary>
14+
/// Any object that implements this interface will automatically have all
15+
/// JsonProperties of all of its implementing interfaces discovered.
16+
/// </summary>
17+
public interface INestSerializable { }
1518
}

‎src/Nest/ElasticClient-AliasExists.cs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public partial class ElasticClient
1414
/// <inheritdoc />
1515
public IExistsResponse AliasExists(Func<AliasExistsDescriptor, AliasExistsDescriptor> selector)
1616
{
17-
return this.Dispatch<AliasExistsDescriptor, AliasExistsRequestParameters, ExistsResponse>(
17+
return this.Dispatcher.Dispatch<AliasExistsDescriptor, AliasExistsRequestParameters, ExistsResponse>(
1818
selector,
1919
(p, d) => this.RawDispatch.IndicesExistsAliasDispatch<ExistsResponse>(
2020
p.DeserializationState(new AliasExistConverter(DeserializeExistsResponse))
@@ -25,7 +25,7 @@ public IExistsResponse AliasExists(Func<AliasExistsDescriptor, AliasExistsDescri
2525
/// <inheritdoc />
2626
public IExistsResponse AliasExists(IAliasExistsRequest AliasRequest)
2727
{
28-
return this.Dispatch<IAliasExistsRequest, AliasExistsRequestParameters, ExistsResponse>(
28+
return this.Dispatcher.Dispatch<IAliasExistsRequest, AliasExistsRequestParameters, ExistsResponse>(
2929
AliasRequest,
3030
(p, d) => this.RawDispatch.IndicesExistsAliasDispatch<ExistsResponse>(
3131
p.DeserializationState(new AliasExistConverter(DeserializeExistsResponse))
@@ -36,7 +36,7 @@ public IExistsResponse AliasExists(IAliasExistsRequest AliasRequest)
3636
/// <inheritdoc />
3737
public Task<IExistsResponse> AliasExistsAsync(Func<AliasExistsDescriptor, AliasExistsDescriptor> selector)
3838
{
39-
return this.DispatchAsync<AliasExistsDescriptor, AliasExistsRequestParameters, ExistsResponse, IExistsResponse>(
39+
return this.Dispatcher.DispatchAsync<AliasExistsDescriptor, AliasExistsRequestParameters, ExistsResponse, IExistsResponse>(
4040
selector,
4141
(p, d) => this.RawDispatch.IndicesExistsAliasDispatchAsync<ExistsResponse>(
4242
p.DeserializationState(new AliasExistConverter(DeserializeExistsResponse))
@@ -47,7 +47,7 @@ public Task<IExistsResponse> AliasExistsAsync(Func<AliasExistsDescriptor, AliasE
4747
/// <inheritdoc />
4848
public Task<IExistsResponse> AliasExistsAsync(IAliasExistsRequest AliasRequest)
4949
{
50-
return this.DispatchAsync<IAliasExistsRequest, AliasExistsRequestParameters, ExistsResponse, IExistsResponse>(
50+
return this.Dispatcher.DispatchAsync<IAliasExistsRequest, AliasExistsRequestParameters, ExistsResponse, IExistsResponse>(
5151
AliasRequest,
5252
(p, d) => this.RawDispatch.IndicesExistsAliasDispatchAsync<ExistsResponse>(
5353
p.DeserializationState(new AliasExistConverter(DeserializeExistsResponse))

‎src/Nest/ElasticClient-Aliases.cs‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public partial class ElasticClient
1515
/// <inheritdoc />
1616
public IIndicesOperationResponse Alias(IAliasRequest aliasRequest)
1717
{
18-
return this.Dispatch<IAliasRequest, AliasRequestParameters, IndicesOperationResponse>(
18+
return this.Dispatcher.Dispatch<IAliasRequest, AliasRequestParameters, IndicesOperationResponse>(
1919
aliasRequest,
2020
(p, d) => this.RawDispatch.IndicesUpdateAliasesDispatch<IndicesOperationResponse>(p, d)
2121
);
@@ -24,7 +24,7 @@ public IIndicesOperationResponse Alias(IAliasRequest aliasRequest)
2424
/// <inheritdoc />
2525
public IIndicesOperationResponse Alias(Func<AliasDescriptor, AliasDescriptor> aliasSelector)
2626
{
27-
return this.Dispatch<AliasDescriptor, AliasRequestParameters, IndicesOperationResponse>(
27+
return this.Dispatcher.Dispatch<AliasDescriptor, AliasRequestParameters, IndicesOperationResponse>(
2828
aliasSelector,
2929
(p, d) => this.RawDispatch.IndicesUpdateAliasesDispatch<IndicesOperationResponse>(p, d)
3030
);
@@ -33,7 +33,7 @@ public IIndicesOperationResponse Alias(Func<AliasDescriptor, AliasDescriptor> al
3333
/// <inheritdoc />
3434
public Task<IIndicesOperationResponse> AliasAsync(IAliasRequest aliasRequest)
3535
{
36-
return this.DispatchAsync<IAliasRequest, AliasRequestParameters, IndicesOperationResponse, IIndicesOperationResponse>(
36+
return this.Dispatcher.DispatchAsync<IAliasRequest, AliasRequestParameters, IndicesOperationResponse, IIndicesOperationResponse>(
3737
aliasRequest,
3838
(p, d) => this.RawDispatch.IndicesUpdateAliasesDispatchAsync<IndicesOperationResponse>(p, d)
3939
);
@@ -42,7 +42,7 @@ public Task<IIndicesOperationResponse> AliasAsync(IAliasRequest aliasRequest)
4242
/// <inheritdoc />
4343
public Task<IIndicesOperationResponse> AliasAsync(Func<AliasDescriptor, AliasDescriptor> aliasSelector)
4444
{
45-
return this.DispatchAsync<AliasDescriptor, AliasRequestParameters, IndicesOperationResponse, IIndicesOperationResponse>(
45+
return this.Dispatcher.DispatchAsync<AliasDescriptor, AliasRequestParameters, IndicesOperationResponse, IIndicesOperationResponse>(
4646
aliasSelector,
4747
(p, d) => this.RawDispatch.IndicesUpdateAliasesDispatchAsync<IndicesOperationResponse>(p, d)
4848
);
@@ -51,7 +51,7 @@ public Task<IIndicesOperationResponse> AliasAsync(Func<AliasDescriptor, AliasDes
5151
/// <inheritdoc />
5252
public IGetAliasesResponse GetAlias(Func<GetAliasDescriptor, GetAliasDescriptor> GetAliasDescriptor)
5353
{
54-
return this.Dispatch<GetAliasDescriptor, GetAliasRequestParameters, GetAliasesResponse>(
54+
return this.Dispatcher.Dispatch<GetAliasDescriptor, GetAliasRequestParameters, GetAliasesResponse>(
5555
GetAliasDescriptor,
5656
(p, d) => this.RawDispatch.IndicesGetAliasDispatch<GetAliasesResponse>(
5757
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -62,7 +62,7 @@ public IGetAliasesResponse GetAlias(Func<GetAliasDescriptor, GetAliasDescriptor>
6262
/// <inheritdoc />
6363
public IGetAliasesResponse GetAlias(IGetAliasRequest GetAliasRequest)
6464
{
65-
return this.Dispatch<IGetAliasRequest, GetAliasRequestParameters, GetAliasesResponse>(
65+
return this.Dispatcher.Dispatch<IGetAliasRequest, GetAliasRequestParameters, GetAliasesResponse>(
6666
GetAliasRequest,
6767
(p, d) => this.RawDispatch.IndicesGetAliasDispatch<GetAliasesResponse>(
6868
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -73,7 +73,7 @@ public IGetAliasesResponse GetAlias(IGetAliasRequest GetAliasRequest)
7373
/// <inheritdoc />
7474
public Task<IGetAliasesResponse> GetAliasAsync(Func<GetAliasDescriptor, GetAliasDescriptor> GetAliasDescriptor)
7575
{
76-
return this.DispatchAsync<GetAliasDescriptor, GetAliasRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
76+
return this.Dispatcher.DispatchAsync<GetAliasDescriptor, GetAliasRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
7777
GetAliasDescriptor,
7878
(p, d) => this.RawDispatch.IndicesGetAliasDispatchAsync<GetAliasesResponse>(
7979
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -84,7 +84,7 @@ public Task<IGetAliasesResponse> GetAliasAsync(Func<GetAliasDescriptor, GetAlias
8484
/// <inheritdoc />
8585
public Task<IGetAliasesResponse> GetAliasAsync(IGetAliasRequest GetAliasRequest)
8686
{
87-
return this.DispatchAsync<IGetAliasRequest, GetAliasRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
87+
return this.Dispatcher.DispatchAsync<IGetAliasRequest, GetAliasRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
8888
GetAliasRequest,
8989
(p, d) => this.RawDispatch.IndicesGetAliasDispatchAsync<GetAliasesResponse>(
9090
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -96,7 +96,7 @@ public Task<IGetAliasesResponse> GetAliasAsync(IGetAliasRequest GetAliasRequest)
9696
/// <inheritdoc />
9797
public IGetAliasesResponse GetAliases(Func<GetAliasesDescriptor, GetAliasesDescriptor> getAliasesDescriptor)
9898
{
99-
return this.Dispatch<GetAliasesDescriptor, GetAliasesRequestParameters, GetAliasesResponse>(
99+
return this.Dispatcher.Dispatch<GetAliasesDescriptor, GetAliasesRequestParameters, GetAliasesResponse>(
100100
getAliasesDescriptor,
101101
(p, d) => this.RawDispatch.IndicesGetAliasesDispatch<GetAliasesResponse>(
102102
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -107,7 +107,7 @@ public IGetAliasesResponse GetAliases(Func<GetAliasesDescriptor, GetAliasesDescr
107107
/// <inheritdoc />
108108
public IGetAliasesResponse GetAliases(IGetAliasesRequest getAliasesRequest)
109109
{
110-
return this.Dispatch<IGetAliasesRequest, GetAliasesRequestParameters, GetAliasesResponse>(
110+
return this.Dispatcher.Dispatch<IGetAliasesRequest, GetAliasesRequestParameters, GetAliasesResponse>(
111111
getAliasesRequest,
112112
(p, d) => this.RawDispatch.IndicesGetAliasesDispatch<GetAliasesResponse>(
113113
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -118,7 +118,7 @@ public IGetAliasesResponse GetAliases(IGetAliasesRequest getAliasesRequest)
118118
/// <inheritdoc />
119119
public Task<IGetAliasesResponse> GetAliasesAsync(Func<GetAliasesDescriptor, GetAliasesDescriptor> getAliasesDescriptor)
120120
{
121-
return this.DispatchAsync<GetAliasesDescriptor, GetAliasesRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
121+
return this.Dispatcher.DispatchAsync<GetAliasesDescriptor, GetAliasesRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
122122
getAliasesDescriptor,
123123
(p, d) => this.RawDispatch.IndicesGetAliasesDispatchAsync<GetAliasesResponse>(
124124
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -129,7 +129,7 @@ public Task<IGetAliasesResponse> GetAliasesAsync(Func<GetAliasesDescriptor, GetA
129129
/// <inheritdoc />
130130
public Task<IGetAliasesResponse> GetAliasesAsync(IGetAliasesRequest getAliasesRequest)
131131
{
132-
return this.DispatchAsync<IGetAliasesRequest, GetAliasesRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
132+
return this.Dispatcher.DispatchAsync<IGetAliasesRequest, GetAliasesRequestParameters, GetAliasesResponse, IGetAliasesResponse>(
133133
getAliasesRequest,
134134
(p, d) => this.RawDispatch.IndicesGetAliasesDispatchAsync<GetAliasesResponse>(
135135
p.DeserializationState(new GetAliasesConverter(DeserializeGetAliasesResponse))
@@ -140,7 +140,7 @@ public Task<IGetAliasesResponse> GetAliasesAsync(IGetAliasesRequest getAliasesRe
140140
/// <inheritdoc />
141141
public IPutAliasResponse PutAlias(IPutAliasRequest putAliasRequest)
142142
{
143-
return this.Dispatch<IPutAliasRequest, PutAliasRequestParameters, PutAliasResponse>(
143+
return this.Dispatcher.Dispatch<IPutAliasRequest, PutAliasRequestParameters, PutAliasResponse>(
144144
putAliasRequest,
145145
(p, d) => this.RawDispatch.IndicesPutAliasDispatch<PutAliasResponse>(p, d)
146146
);
@@ -149,7 +149,7 @@ public IPutAliasResponse PutAlias(IPutAliasRequest putAliasRequest)
149149
/// <inheritdoc />
150150
public Task<IPutAliasResponse> PutAliasAsync(IPutAliasRequest putAliasRequest)
151151
{
152-
return this.DispatchAsync<IPutAliasRequest, PutAliasRequestParameters, PutAliasResponse, IPutAliasResponse>(
152+
return this.Dispatcher.DispatchAsync<IPutAliasRequest, PutAliasRequestParameters, PutAliasResponse, IPutAliasResponse>(
153153
putAliasRequest,
154154
(p, d) => this.RawDispatch.IndicesPutAliasDispatchAsync<PutAliasResponse>(p, d)
155155
);
@@ -158,7 +158,7 @@ public Task<IPutAliasResponse> PutAliasAsync(IPutAliasRequest putAliasRequest)
158158
/// <inheritdoc />
159159
public IPutAliasResponse PutAlias(Func<PutAliasDescriptor, PutAliasDescriptor> putAliasDescriptor)
160160
{
161-
return this.Dispatch<PutAliasDescriptor, PutAliasRequestParameters, PutAliasResponse>(
161+
return this.Dispatcher.Dispatch<PutAliasDescriptor, PutAliasRequestParameters, PutAliasResponse>(
162162
putAliasDescriptor,
163163
(p, d) => this.RawDispatch.IndicesPutAliasDispatch<PutAliasResponse>(p, d)
164164
);
@@ -167,7 +167,7 @@ public IPutAliasResponse PutAlias(Func<PutAliasDescriptor, PutAliasDescriptor> p
167167
/// <inheritdoc />
168168
public Task<IPutAliasResponse> PutAliasAsync(Func<PutAliasDescriptor, PutAliasDescriptor> putAliasDescriptor)
169169
{
170-
return this.DispatchAsync<PutAliasDescriptor, PutAliasRequestParameters, PutAliasResponse, IPutAliasResponse>(
170+
return this.Dispatcher.DispatchAsync<PutAliasDescriptor, PutAliasRequestParameters, PutAliasResponse, IPutAliasResponse>(
171171
putAliasDescriptor,
172172
(p, d) => this.RawDispatch.IndicesPutAliasDispatchAsync<PutAliasResponse>(p, d)
173173
);
@@ -176,7 +176,7 @@ public Task<IPutAliasResponse> PutAliasAsync(Func<PutAliasDescriptor, PutAliasDe
176176
/// <inheritdoc />
177177
public IDeleteAliasResponse DeleteAlias(IDeleteAliasRequest deleteAliasRequest)
178178
{
179-
return this.Dispatch<IDeleteAliasRequest, DeleteAliasRequestParameters, DeleteAliasResponse>(
179+
return this.Dispatcher.Dispatch<IDeleteAliasRequest, DeleteAliasRequestParameters, DeleteAliasResponse>(
180180
deleteAliasRequest,
181181
(p, d) => this.RawDispatch.IndicesDeleteAliasDispatch<DeleteAliasResponse>(p)
182182
);
@@ -185,7 +185,7 @@ public IDeleteAliasResponse DeleteAlias(IDeleteAliasRequest deleteAliasRequest)
185185
/// <inheritdoc />
186186
public Task<IDeleteAliasResponse> DeleteAliasAsync(IDeleteAliasRequest deleteAliasRequest)
187187
{
188-
return this.DispatchAsync<IDeleteAliasRequest, DeleteAliasRequestParameters, DeleteAliasResponse, IDeleteAliasResponse>(
188+
return this.Dispatcher.DispatchAsync<IDeleteAliasRequest, DeleteAliasRequestParameters, DeleteAliasResponse, IDeleteAliasResponse>(
189189
deleteAliasRequest,
190190
(p, d) => this.RawDispatch.IndicesDeleteAliasDispatchAsync<DeleteAliasResponse>(p)
191191
);
@@ -195,7 +195,7 @@ public Task<IDeleteAliasResponse> DeleteAliasAsync(IDeleteAliasRequest deleteAli
195195
public IDeleteAliasResponse DeleteAlias<T>(Func<DeleteAliasDescriptor<T>, DeleteAliasDescriptor<T>> deleteAliasDescriptor)
196196
where T : class
197197
{
198-
return this.Dispatch<DeleteAliasDescriptor<T>, DeleteAliasRequestParameters, DeleteAliasResponse>(
198+
return this.Dispatcher.Dispatch<DeleteAliasDescriptor<T>, DeleteAliasRequestParameters, DeleteAliasResponse>(
199199
deleteAliasDescriptor,
200200
(p, d) => this.RawDispatch.IndicesDeleteAliasDispatch<DeleteAliasResponse>(p)
201201
);
@@ -205,7 +205,7 @@ public IDeleteAliasResponse DeleteAlias<T>(Func<DeleteAliasDescriptor<T>, Delete
205205
public Task<IDeleteAliasResponse> DeleteAliasAsync<T>(Func<DeleteAliasDescriptor<T>, DeleteAliasDescriptor<T>> deleteAliasDescriptor)
206206
where T : class
207207
{
208-
return this.DispatchAsync<DeleteAliasDescriptor<T>, DeleteAliasRequestParameters, DeleteAliasResponse, IDeleteAliasResponse>(
208+
return this.Dispatcher.DispatchAsync<DeleteAliasDescriptor<T>, DeleteAliasRequestParameters, DeleteAliasResponse, IDeleteAliasResponse>(
209209
deleteAliasDescriptor,
210210
(p, d) => this.RawDispatch.IndicesDeleteAliasDispatchAsync<DeleteAliasResponse>(p)
211211
);

‎src/Nest/ElasticClient-Analyze.cs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ public partial class ElasticClient
99
/// <inheritdoc />
1010
public IAnalyzeResponse Analyze(Func<AnalyzeDescriptor, AnalyzeDescriptor> analyzeSelector)
1111
{
12-
return this.Dispatch<AnalyzeDescriptor, AnalyzeRequestParameters, AnalyzeResponse>(
12+
return this.Dispatcher.Dispatch<AnalyzeDescriptor, AnalyzeRequestParameters, AnalyzeResponse>(
1313
analyzeSelector,
1414
(p, d) =>
1515
{
@@ -24,7 +24,7 @@ public IAnalyzeResponse Analyze(Func<AnalyzeDescriptor, AnalyzeDescriptor> analy
2424
/// <inheritdoc />
2525
public IAnalyzeResponse Analyze(IAnalyzeRequest analyzeRequest)
2626
{
27-
return this.Dispatch<IAnalyzeRequest, AnalyzeRequestParameters, AnalyzeResponse>(
27+
return this.Dispatcher.Dispatch<IAnalyzeRequest, AnalyzeRequestParameters, AnalyzeResponse>(
2828
analyzeRequest,
2929
(p, d) =>
3030
{
@@ -39,7 +39,7 @@ public IAnalyzeResponse Analyze(IAnalyzeRequest analyzeRequest)
3939
/// <inheritdoc />
4040
public Task<IAnalyzeResponse> AnalyzeAsync(Func<AnalyzeDescriptor, AnalyzeDescriptor> analyzeSelector)
4141
{
42-
return this.DispatchAsync<AnalyzeDescriptor, AnalyzeRequestParameters, AnalyzeResponse, IAnalyzeResponse>(
42+
return this.Dispatcher.DispatchAsync<AnalyzeDescriptor, AnalyzeRequestParameters, AnalyzeResponse, IAnalyzeResponse>(
4343
analyzeSelector,
4444
(p, d) =>
4545
{
@@ -54,7 +54,7 @@ public Task<IAnalyzeResponse> AnalyzeAsync(Func<AnalyzeDescriptor, AnalyzeDescri
5454
/// <inheritdoc />
5555
public Task<IAnalyzeResponse> AnalyzeAsync(IAnalyzeRequest analyzeRequest)
5656
{
57-
return this.DispatchAsync<IAnalyzeRequest, AnalyzeRequestParameters, AnalyzeResponse, IAnalyzeResponse>(
57+
return this.Dispatcher.DispatchAsync<IAnalyzeRequest, AnalyzeRequestParameters, AnalyzeResponse, IAnalyzeResponse>(
5858
analyzeRequest,
5959
(p, d) =>
6060
{

‎src/Nest/ElasticClient-Bulk.cs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ public partial class ElasticClient
1111
/// <inheritdoc />
1212
public IBulkResponse Bulk(IBulkRequest bulkRequest)
1313
{
14-
return this.Dispatch<IBulkRequest, BulkRequestParameters, BulkResponse>(
14+
return this.Dispatcher.Dispatch<IBulkRequest, BulkRequestParameters, BulkResponse>(
1515
bulkRequest,
1616
(p, d) =>
1717
{
@@ -24,7 +24,7 @@ public IBulkResponse Bulk(IBulkRequest bulkRequest)
2424
/// <inheritdoc />
2525
public IBulkResponse Bulk(Func<BulkDescriptor, BulkDescriptor> bulkSelector)
2626
{
27-
return this.Dispatch<BulkDescriptor, BulkRequestParameters, BulkResponse>(
27+
return this.Dispatcher.Dispatch<BulkDescriptor, BulkRequestParameters, BulkResponse>(
2828
bulkSelector,
2929
(p, d) =>
3030
{
@@ -37,7 +37,7 @@ public IBulkResponse Bulk(Func<BulkDescriptor, BulkDescriptor> bulkSelector)
3737
/// <inheritdoc />
3838
public Task<IBulkResponse> BulkAsync(IBulkRequest bulkRequest)
3939
{
40-
return this.DispatchAsync<IBulkRequest, BulkRequestParameters, BulkResponse, IBulkResponse>(
40+
return this.Dispatcher.DispatchAsync<IBulkRequest, BulkRequestParameters, BulkResponse, IBulkResponse>(
4141
bulkRequest,
4242
(p, d) =>
4343
{
@@ -50,7 +50,7 @@ public Task<IBulkResponse> BulkAsync(IBulkRequest bulkRequest)
5050
/// <inheritdoc />
5151
public Task<IBulkResponse> BulkAsync(Func<BulkDescriptor, BulkDescriptor> bulkSelector)
5252
{
53-
return this.DispatchAsync<BulkDescriptor, BulkRequestParameters, BulkResponse, IBulkResponse>(
53+
return this.Dispatcher.DispatchAsync<BulkDescriptor, BulkRequestParameters, BulkResponse, IBulkResponse>(
5454
bulkSelector,
5555
(p, d) =>
5656
{

0 commit comments

Comments
 (0)