}

  public override fun toString(): String {
    val socketAddress = socketAddress_
    return when {
      closed -> "MockWebServer{closed}"
      socketAddress != null -> "MockWebServer{port=${socketAddress.port}}"
      else -> "MockWebServer{new}"
    }
  }

  /** A buffer wrapper that drops data after [bodyLimit] bytes. */
  private class TruncatingBuffer(

import okhttp3.OkHttpClient
import okhttp3.OkHttpClientTestRule
import okhttp3.Request
import okhttp3.RequestBody
import okhttp3.Response
import okhttp3.mockwebserver.MockResponse
import okhttp3.mockwebserver.MockWebServer
import okhttp3.mockwebserver.SocketPolicy
import okhttp3.testing.PlatformRule
import okio.Buffer
import okio.BufferedSink
import org.junit.jupiter.api.AfterEach
import org.junit.jupiter.api.BeforeEach

        this[OkHttpClient::class.java.name] = "okhttp.OkHttpClient"
        this[Http2::class.java.name] = "okhttp.Http2"
        this[TaskRunner::class.java.name] = "okhttp.TaskRunner"
        this["okhttp3.mockwebserver.MockWebServer"] = "okhttp.MockWebServer"
      }.toMap()

  internal fun androidLog(
    loggerName: String,
    logLevel: Int,
    message: String,
    t: Throwable? = null,
  ) {
    val tag = loggerTag(loggerName)

    }
  }

  @Test
  fun toStringIncludesLifecycleState() {
    val other = MockWebServer()
    assertThat(other.toString()).isEqualTo("MockWebServer{new}")
    other.use {
      other.start()
      assertThat(other.toString()).isEqualTo("MockWebServer{port=${other.port}}")
    }
    assertThat(other.toString()).isEqualTo("MockWebServer{closed}")
  }

  @Test
  fun closeWhileBlockedDispatching() {

import java.util.concurrent.CompletableFuture;

import static org.junit.jupiter.api.Assertions.assertEquals;

public class EventSourceFactoryTest {

  @StartStop
  private final MockWebServer server = new MockWebServer();

  @Test
  public void testEventSourceFactory() throws Exception {
    OkHttpClient client = new OkHttpClient();
    EventSource.Factory factory = EventSource.Factory.create(client);

 */
package okhttp3.internal.http

import assertk.assertThat
import assertk.assertions.isIn
import java.net.Socket
import kotlin.test.assertFailsWith
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import mockwebserver3.junit5.StartStop
import okhttp3.Call
import okhttp3.Connection
import okhttp3.EventListener
import okhttp3.Headers
import okhttp3.OkHttpClientTestRule
import okhttp3.Request

import assertk.assertThat
import assertk.assertions.isEqualTo
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import okhttp3.HttpUrl.Companion.toHttpUrl
import okhttp3.OkHttpClient
import okhttp3.Request
import org.junit.jupiter.api.Test

class SampleTest {
  private val server = MockWebServer()

  private val client = OkHttpClient()

  @Test
  fun passingTest() {

</dependency>
```

MockWebServer
-------------

OkHttp includes a library for testing HTTP, HTTPS, and HTTP/2 clients.

The latest release is available on [Maven Central](https://search.maven.org/artifact/com.squareup.okhttp3/mockwebserver/5.1.0/jar).

```kotlin
testImplementation("com.squareup.okhttp3:mockwebserver3:5.1.0")
```

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

import assertk.assertThat
import assertk.assertions.isEqualTo
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import mockwebserver3.junit5.StartStop
import okhttp3.Headers
import okhttp3.OkHttpClientTestRule
import okhttp3.Request
import okhttp3.sse.EventSource.Companion.processEventSource
import okhttp3.testing.PlatformRule

import assertk.assertions.isEqualTo
import assertk.assertions.isNull
import assertk.assertions.isTrue
import kotlin.test.assertFailsWith
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import mockwebserver3.junit5.StartStop
import okhttp3.Headers.Companion.headersOf
import okhttp3.OkHttpClientTestRule
import okhttp3.Protocol
import okhttp3.RecordingEventListener