From 6024d30e770b2ab3f62346640b54349f94246bc7 Mon Sep 17 00:00:00 2001 From: hantsy Date: Tue, 25 Jul 2023 09:50:44 +0800 Subject: [PATCH] chore: clean codes --- .../java/com/example/demo/DataInitializer.java | 14 +++++++------- .../java/com/example/demo/DemoApplication.java | 17 ----------------- 2 files changed, 7 insertions(+), 24 deletions(-) diff --git a/boot-data-redis/src/main/java/com/example/demo/DataInitializer.java b/boot-data-redis/src/main/java/com/example/demo/DataInitializer.java index 20cfb5f9b..0dfd2b949 100644 --- a/boot-data-redis/src/main/java/com/example/demo/DataInitializer.java +++ b/boot-data-redis/src/main/java/com/example/demo/DataInitializer.java @@ -1,10 +1,13 @@ package com.example.demo; import java.util.UUID; -import lombok.extern.slf4j.Slf4j; + import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; + +import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Flux; +import reactor.core.scheduler.Schedulers; @Component @Slf4j @@ -30,16 +33,13 @@ public void run(String[] args) { return this.posts.save( Post.builder().id(id).title(title).content("content of " + title) .build()); - } - ) - .subscribeOn(Schedulers.boundedElastic()) - ) + }) + .subscribeOn(Schedulers.boundedElastic())) .log() .subscribe( null, null, - () -> log.info("done initialization...") - ); + () -> log.info("done initialization...")); } diff --git a/boot-data-redis/src/main/java/com/example/demo/DemoApplication.java b/boot-data-redis/src/main/java/com/example/demo/DemoApplication.java index e3946736d..402f5ca11 100644 --- a/boot-data-redis/src/main/java/com/example/demo/DemoApplication.java +++ b/boot-data-redis/src/main/java/com/example/demo/DemoApplication.java @@ -6,33 +6,16 @@ import static org.springframework.web.reactive.function.server.RequestPredicates.PUT; import static org.springframework.web.reactive.function.server.RouterFunctions.route; -import java.net.URI; -import java.time.LocalDateTime; -import java.util.UUID; -import lombok.AllArgsConstructor; -import lombok.Builder; -import lombok.Data; -import lombok.NoArgsConstructor; -import lombok.ToString; -import lombok.extern.slf4j.Slf4j; -import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; -import org.springframework.data.annotation.CreatedDate; -import org.springframework.data.annotation.Id; import org.springframework.data.redis.connection.ReactiveRedisConnectionFactory; -import org.springframework.data.redis.core.ReactiveRedisOperations; import org.springframework.data.redis.core.ReactiveRedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.RedisSerializationContext; import org.springframework.data.redis.serializer.StringRedisSerializer; -import org.springframework.stereotype.Component; import org.springframework.web.reactive.function.server.RouterFunction; -import org.springframework.web.reactive.function.server.ServerRequest; import org.springframework.web.reactive.function.server.ServerResponse; -import reactor.core.publisher.Flux; -import reactor.core.publisher.Mono; @SpringBootApplication public class DemoApplication {