File tree Expand file tree Collapse file tree 2 files changed +7
-8
lines changed
spring-messaging/src/test/java/org/springframework/messaging/rsocket Expand file tree Collapse file tree 2 files changed +7
-8
lines changed Original file line number Diff line number Diff line change @@ -25,9 +25,9 @@ configure(allprojects) { project ->
25
25
imports {
26
26
mavenBom " com.fasterxml.jackson:jackson-bom:2.11.2"
27
27
mavenBom " io.netty:netty-bom:4.1.51.Final"
28
- mavenBom " io.projectreactor:reactor-bom:2020.0.0-SNAPSHOT "
28
+ mavenBom " io.projectreactor:reactor-bom:2020.0.0-RC1 "
29
29
mavenBom " io.r2dbc:r2dbc-bom:Arabba-SR6"
30
- mavenBom " io.rsocket:rsocket-bom:1.1.0-SNAPSHOT "
30
+ mavenBom " io.rsocket:rsocket-bom:1.1.0-M2 "
31
31
mavenBom " org.eclipse.jetty:jetty-bom:9.4.31.v20200723"
32
32
mavenBom " org.jetbrains.kotlin:kotlin-bom:1.4.0"
33
33
mavenBom " org.jetbrains.kotlinx:kotlinx-coroutines-bom:1.3.9"
@@ -285,7 +285,7 @@ configure(allprojects) { project ->
285
285
repositories {
286
286
mavenCentral()
287
287
maven { url " https://repo.spring.io/libs-spring-framework-build" }
288
- maven { url " https://repo.spring.io/snapshot " } // Reactor and RSocket
288
+ maven { url " https://repo.spring.io/milestone " } // Reactor
289
289
}
290
290
}
291
291
configurations. all {
Original file line number Diff line number Diff line change 29
29
import io .netty .buffer .ByteBufAllocator ;
30
30
import io .rsocket .ConnectionSetupPayload ;
31
31
import io .rsocket .DuplexConnection ;
32
+ import io .rsocket .RSocketErrorException ;
32
33
import io .rsocket .core .DefaultConnectionSetupPayload ;
33
34
import io .rsocket .core .RSocketConnector ;
34
35
import io .rsocket .frame .decoder .PayloadDecoder ;
@@ -242,14 +243,12 @@ public ByteBuf setupFrame() {
242
243
}
243
244
244
245
@ Override
245
- public Mono < Void > send ( Publisher < ByteBuf > frames ) {
246
- return Mono . empty () ;
246
+ public void sendFrame ( int i , ByteBuf byteBuf ) {
247
+ this . setupFrame = this . setupFrame == null ? byteBuf : this . setupFrame ;
247
248
}
248
249
249
250
@ Override
250
- public Mono <Void > sendOne (ByteBuf frame ) {
251
- this .setupFrame = frame ;
252
- return Mono .empty ();
251
+ public void sendErrorAndClose (RSocketErrorException e ) {
253
252
}
254
253
255
254
@ Override
You can’t perform that action at this time.
0 commit comments