Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use concatWith instead of mergeWith

Browse Source
This commit is contained in:
Arjen Poutsma
2018-09-11 13:24:41 +02:00
parent 1a0522b805
commit 09af706af6
6 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-core/src/test/java/org/springframework/core/codec/ByteArrayDecoderTests.java
View File

@@ -69,7 +69,7 @@ public class ByteArrayDecoderTests extends AbstractDataBufferAllocatingTestCase
public void decodeError() {
DataBuffer fooBuffer = stringBuffer("foo");
Flux<DataBuffer> source =
Flux.just(fooBuffer).mergeWith(Flux.error(new RuntimeException()));
Flux.just(fooBuffer).concatWith(Flux.error(new RuntimeException()));
Flux<byte[]> output = this.decoder.decode(source,
ResolvableType.forClassWithGenerics(Publisher.class, byte[].class),
null, Collections.emptyMap());

2
spring-core/src/test/java/org/springframework/core/codec/ByteBufferDecoderTests.java
View File

@@ -68,7 +68,7 @@ public class ByteBufferDecoderTests extends AbstractDataBufferAllocatingTestCase
public void decodeError() {
DataBuffer fooBuffer = stringBuffer("foo");
Flux<DataBuffer> source =
Flux.just(fooBuffer).mergeWith(Flux.error(new RuntimeException()));
Flux.just(fooBuffer).concatWith(Flux.error(new RuntimeException()));
Flux<ByteBuffer> output = this.decoder.decode(source,
ResolvableType.forClassWithGenerics(Publisher.class, ByteBuffer.class),
null, Collections.emptyMap());

2
spring-core/src/test/java/org/springframework/core/codec/ResourceDecoderTests.java
View File

@@ -77,7 +77,7 @@ public class ResourceDecoderTests extends AbstractDataBufferAllocatingTestCase {
public void decodeError() {
DataBuffer fooBuffer = stringBuffer("foo");
Flux<DataBuffer> source =
Flux.just(fooBuffer).mergeWith(Flux.error(new RuntimeException()));
Flux.just(fooBuffer).concatWith(Flux.error(new RuntimeException()));
Flux<Resource> result = this.decoder

2
spring-core/src/test/java/org/springframework/core/codec/StringDecoderTests.java
View File

@@ -177,7 +177,7 @@ public class StringDecoderTests extends AbstractDataBufferAllocatingTestCase {
public void decodeError() {
DataBuffer fooBuffer = stringBuffer("foo\n");
Flux<DataBuffer> source =
Flux.just(fooBuffer).mergeWith(Flux.error(new RuntimeException()));
Flux.just(fooBuffer).concatWith(Flux.error(new RuntimeException()));
Flux<String> output = this.decoder.decode(source,
ResolvableType.forClass(String.class), null, Collections.emptyMap());