Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ForwardingSink (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top