ReactiveElasticsearchClient should use the same request parameters as non reactive code

Author: faridfaoudi

src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java

@@ -653,6 +653,15 @@ public Mono<Boolean> createIndex(HttpHeaders headers, CreateIndexRequest createI
 				.next();
 	}
 
+	@Override
+	public Mono<Boolean> createIndex(HttpHeaders headers,
+                                     org.elasticsearch.client.indices.CreateIndexRequest createIndexRequest) {
+
+		return sendRequest(createIndexRequest, requestCreator.createIndexRequest(), AcknowledgedResponse.class, headers) //
+				.map(AcknowledgedResponse::isAcknowledged) //
+				.next();
+	}
+
 	@Override
 	public Mono<Void> closeIndex(HttpHeaders headers, CloseIndexRequest closeIndexRequest) {
 
@@ -688,6 +697,14 @@ public Mono<GetMappingsResponse> getMapping(HttpHeaders headers, GetMappingsRequ
 		return sendRequest(getMappingsRequest, requestCreator.getMapping(), GetMappingsResponse.class, headers).next();
 	}
 
+	@Override
+	public Mono<org.elasticsearch.client.indices.GetMappingsResponse> getMapping(HttpHeaders headers,
+             org.elasticsearch.client.indices.GetMappingsRequest getMappingsRequest) {
+		return sendRequest(getMappingsRequest, requestCreator.getMappingRequest(),
+                org.elasticsearch.client.indices.GetMappingsResponse.class, headers) //
+                .next();
+	}
+
 	@Override
 	public Mono<GetFieldMappingsResponse> getFieldMapping(HttpHeaders headers,
 			GetFieldMappingsRequest getFieldMappingsRequest) {
@@ -708,6 +725,14 @@ public Mono<Boolean> putMapping(HttpHeaders headers, PutMappingRequest putMappin
 				.next();
 	}
 
+	@Override
+	public Mono<Boolean> putMapping(HttpHeaders headers,
+                                    org.elasticsearch.client.indices.PutMappingRequest putMappingRequest) {
+        return sendRequest(putMappingRequest, requestCreator.putMappingRequest(), AcknowledgedResponse.class, headers) //
+                .map(AcknowledgedResponse::isAcknowledged) //
+                .next();
+	}
+
 	@Override
 	public Mono<Void> openIndex(HttpHeaders headers, OpenIndexRequest request) {