byte[] chunk3 = newPreFilledByteArray(20); // More data to file

    out.write(chunk1);
    assertThat(out.getFile()).isNull();

    out.write(chunk2);
    assertThat(out.getFile()).isNotNull();
    assertThat(source.read()).isEqualTo(concat(chunk1, chunk2));

    out.write(chunk3);
    assertThat(source.read()).isEqualTo(concat(chunk1, chunk2, chunk3));

    out.reset();
  }

        new AtomicReference<WeakReference<?>>(
            (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));
    assertThat(sepStopwatchA.get()).isNotNull();
    // Clear all references to the Stopwatch and wait for it to be gc'd.
    sepStopwatchA.set(null);
    GcFinalization.awaitClear(sepStopwatchRef.get());

      hp = HostAndPort.fromString(hpString);
    } catch (IllegalArgumentException e) {
      // Make sure we expected this.
      assertThat(expectHost).isNull();
      return;
    }
    assertThat(expectHost).isNotNull();

    // Apply withDefaultPort(), yielding hp2.
    boolean badDefaultPort = defaultPort < 0 || defaultPort > 65535;
    HostAndPort hp2 = null;
    try {
      hp2 = hp.withDefaultPort(defaultPort);

      hp = HostAndPort.fromString(hpString);
    } catch (IllegalArgumentException e) {
      // Make sure we expected this.
      assertThat(expectHost).isNull();
      return;
    }
    assertThat(expectHost).isNotNull();

    // Apply withDefaultPort(), yielding hp2.
    boolean badDefaultPort = defaultPort < 0 || defaultPort > 65535;
    HostAndPort hp2 = null;
    try {
      hp2 = hp.withDefaultPort(defaultPort);

 * limitations under the License.
 */
package okhttp3

import assertk.assertThat
import assertk.assertions.hasMessage
import assertk.assertions.isEqualTo
import assertk.assertions.isNotNull
import assertk.assertions.isNull
import java.io.EOFException
import java.net.ProtocolException
import kotlin.test.assertFailsWith
import okhttp3.Headers.Companion.headersOf
import okhttp3.MediaType.Companion.toMediaType

    Object getResult() {
      if (throwable != null) {
        throw new AssertionError(throwable);
      }
      return result;
    }

    Throwable getThrowable() {
      assertThat(throwable).isNotNull();
      return throwable;
    }
  }

    Object getResult() {
      if (throwable != null) {
        throw new AssertionError(throwable);
      }
      return result;
    }

    Throwable getThrowable() {
      assertThat(throwable).isNotNull();
      return throwable;
    }
  }

  }

  public void testLexicographicalComparatorChoice() {
    Comparator<byte[]> defaultComparator = UnsignedBytes.lexicographicalComparator();
    assertThat(defaultComparator).isNotNull();
    assertThat(UnsignedBytes.lexicographicalComparator()).isSameInstanceAs(defaultComparator);
    if (unsafeComparatorAvailable()) {
      assertThat(defaultComparator).isInstanceOf(UnsafeComparator.class);
    } else {

  }

  public void testLexicographicalComparatorChoice() {
    Comparator<byte[]> defaultComparator = UnsignedBytes.lexicographicalComparator();
    assertThat(defaultComparator).isNotNull();
    assertThat(UnsignedBytes.lexicographicalComparator()).isSameInstanceAs(defaultComparator);
    if (!isJava8()) {
      assertThat(defaultComparator).isInstanceOf(ArraysCompareUnsignedComparator.class);

    Object key = new Object();
    assertThat(cache.getUnchecked(key)).isNotNull();

    CacheTesting.simulateValueReclamation(cache, key);

    // this blocks if computation can't deal with partially-collected values
    assertThat(cache.getUnchecked(key)).isNotNull();
    assertThat(cache.size()).isEqualTo(1);
    assertThat(countingLoader.getCount()).isEqualTo(2);