RedisTimeSupplier implements TimeSupplier { @Override public Mono<Long> getReactive() { return connection.reactive().time() .next() .map(Long::parseLong); } RedisTimeSupplier(StatefulRedisConnection<String, String> connection); @Deprecated @Override CompletionStage<Long> getAsync(); @Override Mono<Long> getReactive(); @Override long get();  }
@Test void shouldGetReactiveSystemCurrentTime() { Long time = new RedisTimeSupplier(connect).getReactive().block(); assertThat(time).isNotNull().isNotNegative().isNotZero(); }