Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for ForwardingSource (0.16 seconds)

  1. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

    import okhttp3.internal.connection.BufferedSocket
    import okhttp3.internal.platform.Platform
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ForwardingSink
    import okio.ForwardingSource
    import okio.asOkioSocket
    import okio.buffer
    
    /**
     * Adapts a [java.net.Socket] to MockWebServer's needs.
     *
     * Note that [asOkioSocket] returns a socket that closes the underlying [java.net.Socket] when both
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  2. 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.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.jupiter.api.fail
    
    class ExecuteAsyncTest {
      @RegisterExtension
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt

    import okhttp3.Response
    import okhttp3.ResponseBody
    import okhttp3.internal.http.ExchangeCodec
    import okhttp3.internal.http.RealResponseBody
    import okio.Buffer
    import okio.ForwardingSink
    import okio.ForwardingSource
    import okio.Sink
    import okio.Socket
    import okio.Source
    import okio.buffer
    
    /**
     * Transmits a single HTTP request and a response pair. This layers connection management and events
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  4. 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:
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ByteString.Companion.decodeHex
    import okio.ByteString.Companion.encodeUtf8
    import okio.ForwardingSink
    import okio.ForwardingSource
    import okio.Socket
    import okio.buffer
    import okio.inMemorySocketPair
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Tag
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 18.7K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/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.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 26.9K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

    import okhttp3.testing.PlatformRule
    import okhttp3.tls.HandshakeCertificates
    import okhttp3.tls.HeldCertificate
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
Back to Top