1 package de.juplo.kafka.chat.backend.implementation.inmemory;
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;
9 import java.time.Clock;
12 public class InMemoryTestUtils
15 StorageStrategy storageStrategy;
18 public Mono<Void> restore(SimpleChatHomeService simpleChatHomeService)
20 return simpleChatHomeService.restore(storageStrategy);