AE
https://www.jetbrains.com/help/idea/code-with-me.html
Size: a a a
AE
e
A
e
AE
A
MK
dataService
.getDataById(id).log().map(r -> {
return new PacketResponse();
})
.repeatWhenEmpty(10, l -> {
return l.delayElements(Duration.ofSeconds(2)).map(c -> { log.info("{}", c); return c+1;});
})
;
Mockito
.when(
dataService.getDataById(anyString())
)
.thenReturn(
Mono.empty(),
Mono.just(new PacketBean())
)
;
MK
AK
b
public class SequenceResetTestExecutionListener extends AbstractTestExecutionListener {
private static final String STATEMENT_TEMPLATE = "ALTER SEQUENCE %s RESTART WITH 1000";
@Override
public void beforeTestMethod(final TestContext testContext) {
final JdbcTemplate jdbcTemplate = testContext.getApplicationContext().getBean(JdbcTemplate.class);
final String[] resetStatements = jdbcTemplate.queryForList("SELECT * FROM INFORMATION_SCHEMA.SEQUENCES").stream()
.map(sequence -> sequence.get("SEQUENCE_NAME"))
.map(sequenceName -> String.format(STATEMENT_TEMPLATE, sequenceName))
.toArray(String[]::new);
if (resetStatements.length > 0) {
jdbcTemplate.batchUpdate(resetStatements);
}
}
@Override
public int getOrder() {
return 0;
}
}A
b
ch
AE
b
AE