- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ForwardingSink (0.11 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseRequestInterceptor.kt
* limitations under the License. */ package okhttp3 import java.io.IOException import okhttp3.Interceptor.Chain import okio.Buffer import okio.BufferedSink import okio.ForwardingSink import okio.Sink import okio.buffer /** Rewrites the request body sent to the server to be all uppercase. */ class UppercaseRequestInterceptor : Interceptor { @Throws(IOException::class)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/io/FaultyFileSystem.kt
* limitations under the License. */ package okhttp3.internal.io import java.io.IOException import okio.Buffer import okio.FileSystem import okio.ForwardingFileSystem import okio.ForwardingSink import okio.Path import okio.Sink class FaultyFileSystem constructor(delegate: FileSystem?) : ForwardingFileSystem(delegate!!) { private val writeFaults: MutableSet<Path> = LinkedHashSet()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt
*/ package okhttp3.internal.cache import java.io.IOException import okio.Buffer import okio.ForwardingSink import okio.Sink /** A sink that never throws IOExceptions, even if the underlying sink does. */ internal open class FaultHidingSink( delegate: Sink, val onException: (IOException) -> Unit, ) : ForwardingSink(delegate) { private var hasErrors = false override fun write( source: Buffer,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
import okhttp3.Response import okhttp3.ResponseBody import okhttp3.internal.http.ExchangeCodec import okhttp3.internal.http.RealResponseBody import okhttp3.internal.ws.RealWebSocket import okio.Buffer import okio.ForwardingSink import okio.ForwardingSource import okio.Sink import okio.Source import okio.buffer /** * Transmits a single HTTP request and a response pair. This layers connection management and events
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
import okio.BufferedSink import okio.BufferedSource import okio.ByteString.Companion.decodeBase64 import okio.ByteString.Companion.encodeUtf8 import okio.ByteString.Companion.toByteString import okio.FileSystem import okio.ForwardingSink import okio.ForwardingSource import okio.Path import okio.Path.Companion.toOkioPath import okio.Sink import okio.Source import okio.buffer /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
import okhttp3.RequestBody.Companion.toRequestBody import okhttp3.ResponseBody.Companion.toResponseBody import okhttp3.TestUtil.assertSuppressed import okio.Buffer import okio.BufferedSink import okio.ForwardingSink import okio.ForwardingSource import okio.GzipSink import okio.Sink import okio.Source import okio.buffer import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Tag
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0)