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

Upgrade to RSocket 1.1-M2 and Reactor 2020.0.0-RC1

Browse Source 
Closes gh-25729
Closes gh-25728
This commit is contained in:
Rossen Stoyanchev
2020-09-14 20:11:27 +01:00
parent 3b0f14fd2e
commit 29885e2b9f
2 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilderTests.java
View File

@@ -29,6 +29,7 @@ import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.rsocket.ConnectionSetupPayload;
import io.rsocket.DuplexConnection;
import io.rsocket.RSocketErrorException;
import io.rsocket.core.DefaultConnectionSetupPayload;
import io.rsocket.core.RSocketConnector;
import io.rsocket.frame.decoder.PayloadDecoder;
@@ -242,14 +243,12 @@ public class DefaultRSocketRequesterBuilderTests {
}
@Override
public Mono<Void> send(Publisher<ByteBuf> frames) {
return Mono.empty();
public void sendFrame(int i, ByteBuf byteBuf) {
this.setupFrame = this.setupFrame == null ? byteBuf : this.setupFrame;
}
@Override
public Mono<Void> sendOne(ByteBuf frame) {
this.setupFrame = frame;
return Mono.empty();
public void sendErrorAndClose(RSocketErrorException e) {
}
@Override