IsClosed - Code Search

android/guava-tests/test/com/google/common/io/CloserTest.java

    TestCloseable c3 = closer.register(TestCloseable.normal());

    assertFalse(c1.isClosed());
    assertFalse(c2.isClosed());
    assertFalse(c3.isClosed());

    closer.close();

    assertTrue(c1.isClosed());
    assertTrue(c2.isClosed());
    assertTrue(c3.isClosed());

    assertTrue(suppressor.suppressions.isEmpty());
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Mar 13 13:01:07 GMT 2026

- 11.9K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/io/CloserTest.java

    TestCloseable c3 = closer.register(TestCloseable.normal());

    assertFalse(c1.isClosed());
    assertFalse(c2.isClosed());
    assertFalse(c3.isClosed());

    closer.close();

    assertTrue(c1.isClosed());
    assertTrue(c2.isClosed());
    assertTrue(c3.isClosed());

    assertTrue(suppressor.suppressions.isEmpty());
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Mar 13 13:01:07 GMT 2026

- 11.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

  internal var writeSuccessCount = 0
  internal var writeAbortCount = 0
  private var networkCount = 0
  private var hitCount = 0
  private var requestCount = 0

  val isClosed: Boolean
    get() = cache.isClosed()

  internal fun get(request: Request): Response? {
    val key = key(request.url)
    val snapshot: DiskLruCache.Snapshot =
      try {
        cache[key] ?: return null

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Mar 20 09:13:37 GMT 2026

- 26.9K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

          new FinalizablePhantomReference<MyServerExampleWithFrq>(myServer, frq) {
            @Override
            public void finalizeReferent() {
              references.remove(this);
              if (!serverSocket.isClosed()) {
                try {
                  serverSocket.close();
                  finalizeReferentRan.set(true);
                } catch (IOException e) {
                  throw new UncheckedIOException(e);

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Feb 27 21:20:19 GMT 2026

- 8.6K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

  @Synchronized
  @Throws(IOException::class)
  override fun flush() {
    if (!initialized) return

    checkNotClosed()
    trimToSize()
    journalWriter!!.flush()
  }

  @Synchronized fun isClosed(): Boolean = closed

  /** Closes this cache. Stored values will remain on the filesystem. */
  @Synchronized
  @Throws(IOException::class)
  override fun close() {
    if (!initialized || closed) {

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 34.7K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/base/FinalizableReferenceQueue.java

 *     Reference<?> reference = new FinalizablePhantomReference<MyServer>(myServer, frq) {
 *       @Override
 *       public void finalizeReferent() {
 *         references.remove(this):
 *         if (!serverSocket.isClosed()) {
 *           ...log a message about how nobody called close()...
 *           try {
 *             serverSocket.close();
 *           } catch (IOException e) {
 *             ...
 *           }
 *         }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 19:26:59 GMT 2026

- 15.8K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/base/FinalizableReferenceQueue.java

 *     Reference<?> reference = new FinalizablePhantomReference<MyServer>(myServer, frq) {
 *       @Override
 *       public void finalizeReferent() {
 *         references.remove(this):
 *         if (!serverSocket.isClosed()) {
 *           ...log a message about how nobody called close()...
 *           try {
 *             serverSocket.close();
 *           } catch (IOException e) {
 *             ...
 *           }
 *         }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 19:26:59 GMT 2026

- 15.8K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/api/jvm/okhttp.api

	public final fun directoryPath ()Lokio/Path;
	public final fun evictAll ()V
	public fun flush ()V
	public final fun hitCount ()I
	public final fun initialize ()V
	public final fun isClosed ()Z
	public static final fun key (Lokhttp3/HttpUrl;)Ljava/lang/String;
	public final fun maxSize ()J
	public final fun networkCount ()I
	public final fun requestCount ()I
	public final fun size ()J

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Mar 10 21:47:20 GMT 2026

- 72.3K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/api/android/okhttp.api

	public final fun directoryPath ()Lokio/Path;
	public final fun evictAll ()V
	public fun flush ()V
	public final fun hitCount ()I
	public final fun initialize ()V
	public final fun isClosed ()Z
	public static final fun key (Lokhttp3/HttpUrl;)Ljava/lang/String;
	public final fun maxSize ()J
	public final fun networkCount ()I
	public final fun requestCount ()I
	public final fun size ()J

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Mar 10 21:47:20 GMT 2026

- 72.3K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

    cache =
      DiskLruCache(filesystem, cacheDir, appVersion, 2, Int.MAX_VALUE.toLong(), taskRunner).also {
        toClose.add(it)
      }
    assertThat(cache.isClosed()).isFalse()
    cache.close()
    assertThat(cache.isClosed()).isTrue()
  }

  @Test
  fun journalWriteFailsDuringEdit() {
    set("a", "a", "a")
    set("b", "b", "b")

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Feb 03 22:17:59 GMT 2026

- 59.4K bytes

- Click Count (0)

Search Options