|
|
|
@ -1,5 +1,5 @@ |
|
|
|
|
/* |
|
|
|
|
* Copyright 2002-2018 the original author or authors. |
|
|
|
|
* Copyright 2002-2019 the original author or authors. |
|
|
|
|
* |
|
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
@ -52,7 +52,8 @@ public class ByteArrayEncoder extends AbstractEncoder<byte[]> { |
|
|
|
|
DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, |
|
|
|
|
@Nullable Map<String, Object> hints) { |
|
|
|
|
|
|
|
|
|
return Flux.from(inputStream).map(bytes -> { |
|
|
|
|
// The following (byte[] bytes) lambda signature declaration is necessary for Eclipse.
|
|
|
|
|
return Flux.from(inputStream).map((byte[] bytes) -> { |
|
|
|
|
DataBuffer dataBuffer = bufferFactory.wrap(bytes); |
|
|
|
|
if (logger.isDebugEnabled() && !Hints.isLoggingSuppressed(hints)) { |
|
|
|
|
String logPrefix = Hints.getLogPrefix(hints); |
|
|
|
|