class RedisTimeSupplier implements TimeSupplier {

    @Override
    public Mono<Long> getReactive() {
        return connection.reactive().time()
                .next()
                .map(Long::parseLong);
    }

    public  RedisTimeSupplier(StatefulRedisConnection<String, String> connection);

}