public void testForwardsToTheWrongMethod() {
    assertFailure(Arithmetic.class, ForwardsToTheWrongMethod::new, "minus");
  }

  public void testFailsToForwardReturnValue() {
    assertFailure(Adder.class, FailsToForwardReturnValue::new, "add(", "Return value");
  }

  public void testFailsToPropagateException() {
    assertFailure(Adder.class, FailsToPropagateException::new, "add(", "exception");
  }

              @Override
              public boolean hasNext() {
                return false;
              }
            };
          }
        };
    assertFailure(tester);
  }

  private static void assertFailure(IteratorTester<?> tester) {
    try {
      tester.test();
    } catch (AssertionError expected) {
      return;
    }
    fail();
  }

  public void testForwardsToTheWrongMethod() {
    assertFailure(Arithmetic.class, ForwardsToTheWrongMethod::new, "minus");
  }

  public void testFailsToForwardReturnValue() {
    assertFailure(Adder.class, FailsToForwardReturnValue::new, "add(", "Return value");
  }

  public void testFailsToPropagateException() {
    assertFailure(Adder.class, FailsToPropagateException::new, "add(", "exception");
  }

              @Override
              public boolean hasNext() {
                return false;
              }
            };
          }
        };
    assertFailure(tester);
  }

  private static void assertFailure(IteratorTester<?> tester) {
    try {
      tester.test();
    } catch (AssertionError expected) {
      return;
    }
    fail();
  }

  }

  fun assertOpen(): WebSocket {
    val event = nextEvent() as Open
    return event.webSocket
  }

  fun assertFailure(t: Throwable?) {
    val event = nextEvent() as Failure
    assertThat(event.response).isNull()
    assertThat(event.t).isSameInstanceAs(t)
  }

  fun assertFailure(
    cls: Class<out IOException?>?,
    vararg messages: String,
  ) {
    val event = nextEvent() as Failure

 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */
package okhttp.android.test

import assertk.all
import assertk.assertFailure
import assertk.assertions.cause
import assertk.assertions.hasClass
import assertk.assertions.hasMessage
import assertk.assertions.isNotNull
import java.io.IOException
import org.junit.Test

  }

  @Test
  fun executionRejectedImmediately() {
    val request = newRequest("http://a/1")
    executor.shutdown()
    client.newCall(request).enqueue(callback)
    callback.await(request.url).assertFailure(InterruptedIOException::class.java)
    assertThat(eventRecorder.recordedEventTypes())
      .containsExactly(CallStart::class, CallFailed::class)
  }

  @Test
  fun executionRejectedAfterMaxRequestsChange() {

 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */
package okhttp.android.test

import assertk.all
import assertk.assertFailure
import assertk.assertions.cause
import assertk.assertions.hasClass
import assertk.assertions.hasMessage
import assertk.assertions.isNotNull
import java.io.IOException
import okhttp3.HttpUrl.Companion.toHttpUrl

    callback.await(server.url("/0")).assertFailure("Too many follow-up requests: 21")
  }

  @Test
  fun http204WithBodyDisallowed() {
    server.enqueue(
      MockResponse(
        code = 204,
        body = "I'm not even supposed to be here today.",
      ),
    )
    executeSynchronously("/")
      .assertFailure("HTTP 204 had non-zero Content-Length: 39")
  }

  }

  fun assertOpen(): EventSource {
    val event = nextEvent() as Open
    return event.eventSource
  }

  fun assertClose() {
    nextEvent() as Closed
  }

  fun assertFailure(
    message: String?,
    code: Int? = null,
  ) {
    val event = nextEvent() as Failure
    if (code != null) {
      assertThat(event.response?.code).isEqualTo(code)
    }
    if (message != null) {