Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for ForwardingSource (0.1 sec)

  1. okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt

    import okhttp3.ResponseBody.Companion.toResponseBody
    import okhttp3.internal.and
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    import okio.ByteString.Companion.decodeHex
    import okio.ForwardingSource
    import okio.buffer
    import org.junit.jupiter.api.Test
    
    class ResponseBodyJvmTest {
      @Test
      fun stringEmpty() {
        val body = body("")
        assertThat(body.string()).isEqualTo("")
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseResponseInterceptor.kt

            }
          }
        return response.newBuilder()
          .body(uppercaseBody)
          .build()
      }
    
      private fun uppercaseSource(source: BufferedSource): ForwardingSource {
        return object : ForwardingSource(source) {
          @Throws(IOException::class)
          override fun read(
            sink: Buffer,
            byteCount: Long,
          ): Long {
            val buffer = Buffer()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

    import okhttp3.HttpUrl.Companion.toHttpUrl
    import okhttp3.OkHttpClientTestRule
    import okhttp3.Protocol
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.ResponseBody
    import okio.Buffer
    import okio.ForwardingSource
    import okio.buffer
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.jupiter.api.fail
    
    class ExecuteAsyncTest {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:24:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/ResponseBodyTest.kt

            override fun contentLength(): Long {
              return 5
            }
    
            override fun source(): BufferedSource {
              val source = Buffer().writeUtf8("hello")
              return object : ForwardingSource(source) {
                override fun close() {
                  closed = true
                  super.close()
                }
              }.buffer()
            }
          }
        body.source().close()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt

    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)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

     */
    package okhttp3.tls.internal.der
    
    import java.math.BigInteger
    import java.net.ProtocolException
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    import okio.ForwardingSource
    import okio.Source
    import okio.buffer
    
    /**
     * Streaming decoder of data encoded following Abstract Syntax Notation One (ASN.1). There are
     * multiple variants of ASN.1, including:
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/Cache.kt

    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
    
    /**
     * Caches HTTP and HTTPS responses to the filesystem so they may be reused, saving time and
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

    import okhttp3.internal.platform.Platform.Companion.WARN
    import okio.BufferedSink
    import okio.FileNotFoundException
    import okio.FileSystem
    import okio.ForwardingFileSystem
    import okio.ForwardingSource
    import okio.Path
    import okio.Sink
    import okio.Source
    import okio.blackholeSink
    import okio.buffer
    
    /**
     * A cache that uses a bounded amount of space on a filesystem. Each cache entry has a string key
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/InterceptorTest.kt

    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
    import org.junit.jupiter.api.Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CallTest.kt

    import okhttp3.testing.Flaky
    import okhttp3.testing.PlatformRule
    import okhttp3.tls.HandshakeCertificates
    import okhttp3.tls.HeldCertificate
    import okio.Buffer
    import okio.BufferedSink
    import okio.ForwardingSource
    import okio.GzipSink
    import okio.Path.Companion.toPath
    import okio.buffer
    import okio.fakefilesystem.FakeFileSystem
    import okio.use
    import org.junit.jupiter.api.AfterEach
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
Back to top