* limitations under the License.
 */
package okhttp3.internal.platform

import android.content.Context
import android.os.Build
import java.lang.IllegalStateException
import okhttp3.internal.platform.android.AndroidLog

actual object PlatformRegistry {
  actual fun findPlatform(): Platform {
    AndroidLog.enable()

    val androidPlatform =

   * when hasNext() is false, so that next() throws a NoSuchElementException, then subsequent calls
   * to remove() will incorrectly throw an IllegalStateException, instead of removing the last
   * element returned.
   *
   * <p>See <a href="https://bugs.openjdk.org/browse/JDK-6529795">JDK-6529795</a>
   */

import com.google.common.base.Supplier;
import com.google.common.collect.ForwardingSet;
import java.util.Set;

/**
 * A subclass of `ForwardingSet` that throws `IllegalStateException` on invocation of any method
 * (except `hashCode` and `equals`) if the provided `Supplier` returns false.
 */
final class InvalidatableSet<E> extends ForwardingSet<E> {
  private final Supplier<Boolean> validator;

      throws ExecutionException {
    try {
      return future.get();
    } catch (InterruptedException e) {
      // Should never be thrown in GWT but play it safe
      throw new IllegalStateException(e);
    }
  }

import com.google.common.base.Supplier;
import com.google.common.collect.ForwardingSet;
import java.util.Set;

/**
 * A subclass of `ForwardingSet` that throws `IllegalStateException` on invocation of any method
 * (except `hashCode` and `equals`) if the provided `Supplier` returns false.
 */
final class InvalidatableSet<E> extends ForwardingSet<E> {
  private final Supplier<Boolean> validator;

        final Exception outerCause = new IllegalStateException("State error", innerCause);
        final JobProcessingException exception = new JobProcessingException(outerCause);

        assertNotNull(exception.getMessage());
        assertTrue(exception.getMessage().contains("IllegalStateException"));
        assertTrue(exception.getMessage().contains("State error"));
    }

  public void start() throws Exception {
    if (mockWebServer != null) throw new IllegalStateException();

    mockWebServer = new MockWebServer();
    mockWebServer.setDispatcher(this);
    mockWebServer.start(slackApi.port);
  }

  public HttpUrl newAuthorizeUrl(String scopes, String team, Listener listener) {
    if (mockWebServer == null) throw new IllegalStateException();

    ByteString state = randomToken();
    synchronized (this) {

     */
    private Mac createMacInstance() throws GeneralSecurityException {
        if (this.closed) {
            throw new IllegalStateException("SigningDigest is closed");
        }
        if (this.signingKey == null) {
            throw new IllegalStateException("Signing key has been wiped");
        }
        Mac m;
        if (this.provider != null) {

     * Gets a buffer from the cache or creates a new one if the cache is empty.
     *
     * Performance: O(1) operation using concurrent queue
     *
     * @return a byte buffer for SMB operations
     * @throws IllegalStateException if buffer size exceeds maximum allowed
     */
    static public byte[] getBuffer() {
        // Try to get from cache first - O(1) operation
        byte[] buf = bufferQueue.poll();
        if (buf != null) {

    assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)
    assertThat(checkDuration("timeout", 1, TimeUnit.MILLISECONDS)).isEqualTo(1)

    assertThat(
      assertThrows<IllegalStateException> {
        checkDuration("timeout", -1, TimeUnit.MILLISECONDS)
      },
    ).hasMessage("timeout < 0")
    assertThat(
      assertThrows<IllegalArgumentException> {