docs: @Override
      public RFuture<V> pollFromAnyAsync(long timeout, TimeUnit unit, String... queueNames) {
          RFuture<V> takeFuture = commandExecutor.pollFromAnyAsync(getName(), codec, RedisCommands.BLPOP_VALUE, toSeconds(timeout, unit), queueNames);
          return wrapTakeFuture(takeFuture);
      }