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

LettuceReactiveKeyCommands.pExpireAt calls EXPIREAT command instead of PEXPIREAT

    XMLWordPrintable

    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: