juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/InMemoryTestUtils.java

   1 package de.juplo.kafka.chat.backend.implementation.inmemory;
   2
   3 import de.juplo.kafka.chat.backend.ChatBackendProperties;
   4 import de.juplo.kafka.chat.backend.domain.ChatHomeService;
   5 import de.juplo.kafka.chat.backend.implementation.StorageStrategy;
   6 import org.springframework.beans.factory.annotation.Autowired;
   7 import reactor.core.publisher.Mono;
   8
   9 import java.time.Clock;
  10
  11
  12 public class InMemoryTestUtils
  13 {
  14   @Autowired
  15   StorageStrategy storageStrategy;
  16
  17
  18   public Mono<Void> restore(SimpleChatHomeService simpleChatHomeService)
  19   {
  20     return simpleChatHomeService.restore(storageStrategy);
  21   }
  22 }