return new PluginsMetadataGenerator(session, request);
    }

    @Override
    public MetadataGenerator newInstance(RepositorySystemSession session, DeployRequest request) {
        return new PluginsMetadataGenerator(session, request);
    }

    @Override
    public float getPriority() {
        return 10; // G level MD should be deployed as 3rd MD
    }

        return new LocalSnapshotMetadataGenerator(session, request);
    }

    @Override
    public MetadataGenerator newInstance(RepositorySystemSession session, DeployRequest request) {
        return new RemoteSnapshotMetadataGenerator(session, request);
    }

    @Override
    public float getPriority() {
        return 30; // GAV level metadata should be deployed 1st MD
    }

        return new VersionsMetadataGenerator(session, request);
    }

    @Override
    public MetadataGenerator newInstance(RepositorySystemSession session, DeployRequest request) {
        return new VersionsMetadataGenerator(session, request);
    }

    @Override
    public float getPriority() {
        return 20; // GA level metadata should be deployed 2nd MD
    }

        this.repository = repository;
    }

    @Override
    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }

    @Override
    public String getArtifactId() {
        return artifactId;
    }

    public void setArtifactId(String artifactId) {
        this.artifactId = artifactId;
    }

    }

    private static String constructMessage(MavenProject project, Artifact artifact) {
        return DEFAULT_MESSAGE + " (project: " + project.getId() + "; illegal attachment: " + artifact.getId() + ")";
    }

    public MavenProject getProject() {
        return project;
    }

    public Artifact getArtifact() {
        return artifact;
    }

      throws InterruptedException, ExecutionException {
    return future.getFromAlreadyDoneTrustedFuture();
  }

  static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
      throws InterruptedException, ExecutionException, TimeoutException {
    checkNotNull(unit);
    return future.getFromAlreadyDoneTrustedFuture();
  }

  private Platform() {}

        public void testOperationsWithNullBuffer() {
            // Given
            smbComTreeDisconnect = new SmbComTreeDisconnect(config);

            // When & Then - operations return 0 even with null buffer (no buffer access since methods return 0)
            assertEquals(0, smbComTreeDisconnect.writeParameterWordsWireFormat(null, 0));
            assertEquals(0, smbComTreeDisconnect.writeBytesWireFormat(null, 0));

        protected int writeSetupWireFormat(byte[] dst, int dstIndex) {
            return 0;
        }

        @Override
        protected int writeParametersWireFormat(byte[] dst, int dstIndex) {
            return 0;
        }

        @Override
        protected int writeDataWireFormat(byte[] dst, int dstIndex) {
            return 0;
        }

        @Override

    @Override
    public Integer get() {
      return ++value;
    }

    @Override
    public boolean equals(@Nullable Object obj) {
      if (obj instanceof CountingSupplier) {
        return this.value == ((CountingSupplier) obj).value;
      }
      return false;
    }

    @Override
    public int hashCode() {
      return value;
    }
  }

  public void testForSupplier() {

			db.AddError(fmt.Errorf("%w when using preload", gorm.ErrModelValueRequired))
			return
		}

		joins := make([]string, 0, len(db.Statement.Joins))
		for _, join := range db.Statement.Joins {
			joins = append(joins, join.Name)
		}

		tx := preloadDB(db, db.Statement.ReflectValue, db.Statement.Dest)
		if tx.Error != nil {
			return
		}