Uploaded image for project: 'Spring Data Redis'
  1. Spring Data Redis
  2. DATAREDIS-1031

LettuceReactiveKeyCommands.pExpireAt calls EXPIREAT command instead of PEXPIREAT

    Details

      Description

      @Override
      public Flux<BooleanResponse<ExpireAtCommand>> pExpireAt(Publisher<ExpireAtCommand> commands) {
      
       return connection.execute(cmd -> Flux.from(commands).concatMap(command -> {
      
       Assert.notNull(command.getKey(), "Key must not be null!");
       Assert.notNull(command.getExpireAt(), "Expire at must not be null!");
      
       return cmd.expireat(command.getKey(), command.getExpireAt().toEpochMilli())
       .map(value -> new BooleanResponse<>(command, value));
       }));
      }

      i think it should be cmd.pexpireat 

      default Mono<Boolean> pExpire(ByteBuffer key, Duration timeout) {
      
         Assert.notNull(key, "Key must not be null!");
         Assert.notNull(timeout, "Timeout must not be null!");
      
         return expire(Mono.just(new ExpireCommand(key, timeout))).next().map(BooleanResponse::getOutput);
      }
      

       i think it should be cmd.pexpire

       

        Attachments

          Activity

            People

            • Assignee:
              mp911de Mark Paluch
              Reporter:
              wkx kaixuan.wu
              Last updater:
              Mark Paluch
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: