Skip to content

Commit fa1c65e

Browse files
committed
Updated CredentialsSupplier interface (made it functional interface)
1 parent 16fa169 commit fa1c65e

File tree

2 files changed

+8
-11
lines changed

2 files changed

+8
-11
lines changed

services-api/src/main/java/io/scalecube/services/auth/CredentialsSupplier.java

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,13 @@
22

33
import io.scalecube.services.ServiceReference;
44
import java.util.Map;
5+
import java.util.function.Function;
56
import reactor.core.publisher.Mono;
67

8+
/**
9+
* Returns credentials for the given {@link ServiceReference}. Credentials are being returned in
10+
* most generic form which is {@code Map<String, String>}.
11+
*/
712
@FunctionalInterface
8-
public interface CredentialsSupplier {
9-
10-
/**
11-
* Returns credentials for the given {@link ServiceReference}.
12-
*
13-
* @param serviceReference target serviceReference
14-
* @return mono result
15-
*/
16-
Mono<Map<String, String>> getCredentials(ServiceReference serviceReference);
17-
}
13+
public interface CredentialsSupplier
14+
extends Function<ServiceReference, Mono<Map<String, String>>> {}

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ private Mono<Map<String, String>> getCredentials(ServiceReference serviceReferen
8888
return Mono.just(Collections.emptyMap());
8989
}
9090
return credentialsSupplier
91-
.getCredentials(serviceReference)
91+
.apply(serviceReference)
9292
.switchIfEmpty(Mono.just(Collections.emptyMap()))
9393
.doOnSuccess(
9494
creds ->

0 commit comments

Comments
 (0)