/**
   * All registered subscribers, indexed by event type.
   *
   * <p>The {@link CopyOnWriteArraySet} values make it easy and relatively lightweight to get an
   * immutable snapshot of all current subscribers to an event without any locking.
   */
  private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers =
      Maps.newConcurrentMap();

  /** The event bus this registry belongs to. */

 * {@link org.apache.maven.api.di.SessionScoped} annotation.</p>
 *
 * <p>Key capabilities provided through the Session include:</p>
 * <ul>
 *   <li>Access to the current {@link org.apache.maven.api.Project}</li>
 *   <li>Access to the {@link org.apache.maven.api.LocalRepository} and {@link org.apache.maven.api.RemoteRepository} configurations</li>

        assertNotNull(dependencies, "dependencies element should be created");

        String xmlOutput = DomUtils.toXml(doc);

        // Verify elements are created and positioned correctly
        int versionIndex = xmlOutput.indexOf("<version>1.0.0</version>");
        int propertiesIndex = xmlOutput.indexOf("<properties>");
        int dependenciesIndex = xmlOutput.indexOf("<dependencies>");

        return _instance;
    }

    // ===================================================================================
    //                                                                       Current DBDef
    //                                                                       =============
    @Override
    public String getProjectName() {
        return null;
    }

    @Override

        assertNotSame(first, second, "Should create new connection when session limit reached");
    }

    @Test
    @DisplayName("Should access fail counts map correctly")
    void testFailCountsAccess() throws Exception {
        // Given: Access to fail counts via reflection
        Field failCountsField = SmbTransportPoolImpl.class.getDeclaredField("failCounts");

    CacheTesting.drainRecencyQueues(cache);
    assertThat(keySet).contains(0);
  }

  public void testEviction_invalidateAll() {
    // test that .invalidateAll() resets total weight state correctly
    IdentityLoader<Integer> loader = identityLoader();
    LoadingCache<Integer, Integer> cache =
        CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(10).build(loader);

    }

    /**
     *
     */
    @Test
    public void testArrayMapIteratorNextException() {
        exception.expect(NoSuchElementException.class);
        exception.expectMessage(is("current=1"));
        ArrayMap<String, String> m = new ArrayMap<String, String>(1);
        Iterator<Map.Entry<String, String>> i = m.entrySet().iterator();
        i.next();
        i.next();
    }

    /**

        return _instance;
    }

    // ===================================================================================
    //                                                                       Current DBDef
    //                                                                       =============
    @Override
    public String getProjectName() {
        return null;
    }

    @Override

     * @return true if cache has changes
     */
    public boolean hasChanges() {
        return hasChanges;
    }

    /**
     * Get and increment inconsistency count
     *
     * @return the current inconsistency count
     */
    public int getInconsistencyCount() {
        return inconsistencyCount.getAndIncrement();
    }

    /**
     * Reset inconsistency count
     */

  if (project.name != "okhttp") {
    val testRuntimeOnly: Configuration by configurations.getting
    dependencies {
      // https://junit.org/junit5/docs/current/user-guide/#running-tests-build-gradle-bom
      testRuntimeOnly(rootProject.libs.junit.jupiter.engine)
      testRuntimeOnly(rootProject.libs.junit.vintage.engine)
      testRuntimeOnly(rootProject.libs.junit.platform.launcher)