Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for MockWebServerSocket (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  2. github.com/square/okhttp

    mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt 

    import assertk.assertThat
import assertk.assertions.isEqualTo
import java.net.InetAddress
import java.net.Socket
import mockwebserver3.internal.DEFAULT_REQUEST_LINE_HTTP_1
import mockwebserver3.internal.MockWebServerSocket
import mockwebserver3.internal.RecordedRequest
import mockwebserver3.internal.decodeRequestLine
import okhttp3.Headers
import okhttp3.Headers.Companion.headersOf
import okio.Buffer
import okio.ByteString
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 02 20:36:00 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  3. github.com/square/okhttp

    mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt 

    import okio.Sink

/**
 * A sink that sleeps [periodDelayNanos] every [bytesPerPeriod] bytes. Unlike [okio.Throttler],
 * this permits any interval to be used.
 */
internal class ThrottledSink(
  private val socket: MockWebServerSocket,
  private val delegate: Sink,
  private val bytesPerPeriod: Long,
  private val periodDelayNanos: Long,
) : Sink by delegate {
  private var bytesWrittenSinceLastDelay = 0L

  override fun write(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 12:43:16 GMT 2025
    - 1.5K bytes
    - Click Count (0)
Back to Top