Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 55 for BufferedSink (0.08 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.idn
    
    import okio.BufferedSink
    
    /**
     * An IDNA mapping table optimized for small code and data size.
     *
     * Code Points in Sections
     * =======================
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 9K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt

    import mockwebserver3.MockWebServer
    import mockwebserver3.junit5.StartStop
    import okhttp3.MediaType.Companion.toMediaTypeOrNull
    import okhttp3.TestUtil.repeat
    import okhttp3.testing.Flaky
    import okio.BufferedSink
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    
    @Timeout(30)
    @Tag("Slow")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

    import okhttp3.internal.deleteIfExists
    import okhttp3.internal.isCivilized
    import okhttp3.internal.okHttpName
    import okhttp3.internal.platform.Platform
    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
    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)
  4. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.idn
    
    import java.io.IOException
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import okio.Options
    
    /**
     * A decoded [mapping table] that can perform the [mapping step] of IDNA processing.
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

    import okhttp3.internal.http2.Http2.frameLogWindowUpdate
    import okhttp3.internal.writeMedium
    import okio.Buffer
    import okio.BufferedSink
    
    /** Writes HTTP/2 transport frames. */
    @Suppress("NAME_SHADOWING")
    class Http2Writer(
      private val sink: BufferedSink,
      private val client: Boolean,
    ) : Closeable,
      Lockable {
      private val hpackBuffer: Buffer = Buffer()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

    import okhttp3.internal.connection.RealConnectionPool.Companion.get
    import okhttp3.logging.HttpLoggingInterceptor
    import okhttp3.testing.Flaky
    import okhttp3.testing.PlatformRule
    import okio.Buffer
    import okio.BufferedSink
    import org.hamcrest.BaseMatcher
    import org.hamcrest.CoreMatchers
    import org.hamcrest.Description
    import org.hamcrest.Matcher
    import org.hamcrest.MatcherAssert
    import org.junit.Assume.assumeThat
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

    import okhttp3.internal.http.CancelTest.ConnectionType.HTTP
    import okhttp3.internal.http.CancelTest.ConnectionType.HTTPS
    import okhttp3.testing.PlatformRule
    import okio.Buffer
    import okio.BufferedSink
    import org.junit.jupiter.api.Assertions.assertEquals
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

    import okhttp3.internal.RecordingOkAuthenticator
    import okhttp3.internal.duplex.AsyncRequestBody
    import okhttp3.internal.duplex.MockSocketHandler
    import okhttp3.testing.PlatformRule
    import okio.BufferedSink
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Assertions.assertTrue
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Disabled
    import org.junit.jupiter.api.Tag
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

    import okhttp3.Response
    import okhttp3.TestUtil.repeat
    import okhttp3.internal.concurrent.TaskFaker
    import okhttp3.internal.connection.BufferedSocket
    import okhttp3.internal.ws.WebSocketExtensions.Companion.parse
    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
    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)
  10. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

          MockResponse(body = "abc"),
        )
        val sinkReference = AtomicReference<BufferedSink>()
        val response =
          getResponse(
            Request(
              url = server.url("/"),
              body =
                object : ForwardingRequestBody(transferKind.newRequestBody("def")) {
                  override fun writeTo(sink: BufferedSink) {
                    sinkReference.set(sink)
                    super.writeTo(sink)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
Back to Top