This commit is contained in:
Stéphane Nicoll
2024-01-17 17:43:47 +01:00
parent 699da7c383
commit f5b0d9509d
45 changed files with 373 additions and 411 deletions

View File

@@ -42,7 +42,7 @@ class HeadersMethodArgumentResolverTests {
private final HeadersMethodArgumentResolver resolver = new HeadersMethodArgumentResolver();
private Message<byte[]> message =
private final Message<byte[]> message =
MessageBuilder.withPayload(new byte[0]).copyHeaders(Collections.singletonMap("foo", "bar")).build();
private final ResolvableMethod resolvable = ResolvableMethod.on(getClass()).named("handleMessage").build();
@@ -62,7 +62,7 @@ class HeadersMethodArgumentResolverTests {
}
@Test
public void resolveArgumentAnnotated() {
void resolveArgumentAnnotated() {
MethodParameter param = this.resolvable.annotPresent(Headers.class).arg(Map.class, String.class, Object.class);
Map<String, Object> headers = resolveArgument(param);
assertThat(headers.get("foo")).isEqualTo("bar");

View File

@@ -81,7 +81,7 @@ class DefaultRSocketRequesterBuilderTests {
@Test
public void rsocketConnectorConfigurer() {
void rsocketConnectorConfigurer() {
Consumer<RSocketStrategies.Builder> strategiesConfigurer = mock();
RSocketRequester.builder()
.rsocketConnector(this.connectorConfigurer)