Renamed ReactiveHttpOutputMessage dataBufferFactory() method to bufferFactory()

This commit is contained in:
Arjen Poutsma 2016-05-27 10:37:04 +02:00
parent d36286c7d1
commit 03fe209862
7 changed files with 7 additions and 7 deletions

View File

@ -54,6 +54,6 @@ public interface ReactiveHttpOutputMessage extends HttpMessage {
* @return a buffer factory
* @see #setBody(Publisher)
*/
DataBufferFactory dataBufferFactory();
DataBufferFactory bufferFactory();
}

View File

@ -63,7 +63,7 @@ public class ReactorClientHttpRequest extends AbstractClientHttpRequest {
}
@Override
public DataBufferFactory dataBufferFactory() {
public DataBufferFactory bufferFactory() {
return this.dataBufferFactory;
}

View File

@ -61,7 +61,7 @@ public class RxNettyClientHttpRequest extends AbstractClientHttpRequest {
}
@Override
public DataBufferFactory dataBufferFactory() {
public DataBufferFactory bufferFactory() {
return this.dataBufferFactory;
}

View File

@ -128,7 +128,7 @@ public class CodecHttpMessageConverter<T> implements HttpMessageConverter<T> {
if (headers.getContentType() == null) {
headers.setContentType(contentType);
}
DataBufferFactory dataBufferFactory = outputMessage.dataBufferFactory();
DataBufferFactory dataBufferFactory = outputMessage.bufferFactory();
Flux<DataBuffer> body =
this.encoder.encode(inputStream, dataBufferFactory, type, contentType);
return outputMessage.setBody(body);

View File

@ -66,7 +66,7 @@ public abstract class AbstractServerHttpResponse implements ServerHttpResponse {
}
@Override
public final DataBufferFactory dataBufferFactory() {
public final DataBufferFactory bufferFactory() {
return this.dataBufferFactory;
}

View File

@ -149,7 +149,7 @@ public class DefaultHttpRequestBuilder implements HttpRequestBuilder {
if (messageEncoder.isPresent()) {
request.setBody(messageEncoder.get()
.encode(this.contentPublisher, request.dataBufferFactory(),
.encode(this.contentPublisher, request.bufferFactory(),
requestBodyType, mediaType));
}
else {

View File

@ -86,7 +86,7 @@ public class MockServerHttpResponse implements ServerHttpResponse {
}
@Override
public DataBufferFactory dataBufferFactory() {
public DataBufferFactory bufferFactory() {
return this.dataBufferFactory;
}