Start building against Reactor 2022.0.1 SNAPSHOTs
See gh-33475
This commit is contained in:
parent
ce33ec19cd
commit
928df41f61
|
|
@ -1157,7 +1157,7 @@ bom {
|
|||
]
|
||||
}
|
||||
}
|
||||
library("Reactor Bom", "2022.0.0") {
|
||||
library("Reactor Bom", "2022.0.1-SNAPSHOT") {
|
||||
group("io.projectreactor") {
|
||||
imports = [
|
||||
"reactor-bom"
|
||||
|
|
|
|||
|
|
@ -16,8 +16,11 @@
|
|||
|
||||
package org.springframework.boot.test.autoconfigure.data.r2dbc;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
import io.r2dbc.spi.ConnectionFactory;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import reactor.core.publisher.Flux;
|
||||
import reactor.test.StepVerifier;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
|
@ -46,7 +49,8 @@ class DataR2dbcTestIntegrationTests {
|
|||
|
||||
@Test
|
||||
void testDatabaseClient() {
|
||||
this.databaseClient.sql("SELECT * FROM example").fetch().all().as(StepVerifier::create).verifyComplete();
|
||||
Flux<Map<String, Object>> all = this.databaseClient.sql("SELECT * FROM example").fetch().all();
|
||||
StepVerifier.create(all).expectNextCount(1).verifyComplete();
|
||||
}
|
||||
|
||||
@Test
|
||||
|
|
|
|||
|
|
@ -1,2 +1,3 @@
|
|||
drop table if exists example;
|
||||
create table example (id int, name varchar);
|
||||
insert into example VALUES (1, 'Spring Boot');
|
||||
|
|
|
|||
Loading…
Reference in New Issue