Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for racingReaders (0.04 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache2/RelayTest.kt

        assertThat(relay.isClosed).isFalse()
        source2!!.close()
        assertThat(relay.isClosed).isTrue()
        assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null)
      }
    
      @Test
      fun racingReaders() {
        val pipe = Pipe(1024)
        val sink = pipe.sink.buffer()
        val relay = edit(file, pipe.source, metadata, 5)
        val future1 = executor.submit(sourceReader(relay.newSource()))
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.1K bytes
    - Viewed (0)
Back to top