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

Minor sample refactoring

Browse Source
This commit is contained in:
Rossen Stoyanchev
2021-07-21 16:06:12 +01:00
parent 39702b9745
commit 0dbc3f12cd
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
samples/webflux-websocket/src/main/java/io/spring/sample/graphql/DataRepository.java
View File

@@ -29,25 +29,25 @@ import org.springframework.stereotype.Repository;
@Repository
public class DataRepository {
public String getBasic(DataFetchingEnvironment environment) {
public String getBasic() {
return "Hello world!";
}
public Mono<String> getGreeting(DataFetchingEnvironment environment) {
public Mono<String> getGreeting() {
return Mono.deferContextual(context -> {
Object name = context.get("name");
return Mono.delay(Duration.ofMillis(50)).map(aLong -> "Hello " + name);
});
}
public Flux<String> getGreetings(DataFetchingEnvironment environment) {
public Flux<String> getGreetings() {
return Mono.delay(Duration.ofMillis(50)).flatMapMany(aLong -> Flux.deferContextual(context -> {
String name = context.get("name");
return Flux.just("Hi", "Bonjour", "Hola", "Ciao", "Zdravo").map(s -> s + " " + name);
}));
}
public Flux<String> getGreetingsStream(DataFetchingEnvironment environment) {
public Flux<String> getGreetingsStream() {
return Mono.delay(Duration.ofMillis(50)).flatMapMany(aLong -> Flux.deferContextual(context -> {
String name = context.get("name");
return Flux.just("Hi", "Bonjour", "Hola", "Ciao", "Zdravo").map(s -> s + " " + name);

8
samples/webflux-websocket/src/main/java/io/spring/sample/graphql/SampleWiring.java
View File

@@ -32,10 +32,10 @@ public class SampleWiring implements RuntimeWiringBuilderCustomizer {
@Override
public void customize(RuntimeWiring.Builder wiringBuilder) {
wiringBuilder.type("Query", builder -> builder.dataFetcher("greeting", this.repository::getBasic));
wiringBuilder.type("Query", builder -> builder.dataFetcher("greetingMono", this.repository::getGreeting));
wiringBuilder.type("Query", builder -> builder.dataFetcher("greetingsFlux", this.repository::getGreetings));
wiringBuilder.type("Subscription", builder -> builder.dataFetcher("greetings", this.repository::getGreetingsStream));
wiringBuilder.type("Query", builder -> builder.dataFetcher("greeting", env -> this.repository.getBasic()));
wiringBuilder.type("Query", builder -> builder.dataFetcher("greetingMono", env -> this.repository.getGreeting()));
wiringBuilder.type("Query", builder -> builder.dataFetcher("greetingsFlux", env -> this.repository.getGreetings()));
wiringBuilder.type("Subscription", builder -> builder.dataFetcher("greetings", env -> this.repository.getGreetingsStream()));
}
}