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

Add Consumer methods to RSocketRequester

Browse Source 
Closes gh-23513
This commit is contained in:
Rossen Stoyanchev
2019-09-02 13:30:29 +01:00
parent b144c72937
commit 58e9266e99
3 changed files with 30 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequester.java
View File

@@ -18,6 +18,7 @@ package org.springframework.messaging.rsocket;
import java.util.Collections;
import java.util.Map;
import java.util.function.Consumer;
import io.rsocket.Payload;
import io.rsocket.RSocket;
@@ -133,6 +134,12 @@ final class DefaultRSocketRequester implements RSocketRequester {
return this;
}
@Override
public RequestSpec metadata(Consumer<RequestSpec> configurer) {
configurer.accept(this);
return this;
}
@Override
public ResponseSpec data(Object data) {
Assert.notNull(data, "'data' must not be null");

6
spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilder.java
View File

@@ -135,6 +135,12 @@ final class DefaultRSocketRequesterBuilder implements RSocketRequester.Builder {
return this;
}
@Override
public RSocketRequester.Builder apply(Consumer<RSocketRequester.Builder> configurer) {
configurer.accept(this);
return this;
}
@Override
public Mono<RSocketRequester> connectTcp(String host, int port) {
return connect(TcpClientTransport.create(host, port));

17
spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java
View File

@@ -197,6 +197,14 @@ public interface RSocketRequester {
*/
RSocketRequester.Builder rsocketFactory(ClientRSocketFactoryConfigurer configurer);
/**
* Configure this builder through a {@code Consumer}. This enables
* libraries such as Spring Security to provide shortcuts for applying
* a set of related customizations.
* @param configurer the configurer to apply
*/
RSocketRequester.Builder apply(Consumer<RSocketRequester.Builder> configurer);
/**
* Connect to the server over TCP.
* @param host the server host
@@ -240,6 +248,15 @@ public interface RSocketRequester {
*/
RequestSpec metadata(Object metadata, MimeType mimeType);
/**
* Append additional metadata entries through a {@code Consumer}.
* This enables libraries such as Spring Security to provide shortcuts
* for applying a set of customizations.
* @param configurer the configurer to apply
* @throws IllegalArgumentException if not using composite metadata.
*/
RequestSpec metadata(Consumer<RequestSpec> configurer);
/**
* Provide payload data for the request. This can be one of:
* <ul>