- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for TriggerSink (0.17 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/internal/TriggerSink.kt
package mockwebserver3.internal import okio.Buffer import okio.Sink /** * A sink that executes [trigger] after [triggerByteCount] bytes are written, and then skips all * subsequent bytes. */ internal class TriggerSink( private val delegate: Sink, private val triggerByteCount: Long, private val trigger: () -> Unit, ) : Sink by delegate { private var bytesWritten = 0L override fun write( source: Buffer,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
import mockwebserver3.SocketPolicy.ShutdownServerAfterResponse import mockwebserver3.SocketPolicy.StallSocketAtStart import mockwebserver3.internal.ThrottledSink import mockwebserver3.internal.TriggerSink import mockwebserver3.internal.duplex.RealStream import mockwebserver3.internal.sleepNanos import okhttp3.ExperimentalOkHttpApi import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.HttpUrl
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0)