Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for BufferedSink (0.15 sec)

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

    import okhttp3.Headers.Companion.headersOf
    import okhttp3.MediaType.Companion.toMediaType
    import okhttp3.MediaType.Companion.toMediaTypeOrNull
    import okhttp3.RequestBody.Companion.toRequestBody
    import okio.Buffer
    import okio.BufferedSink
    import okio.utf8Size
    import org.junit.jupiter.api.Test
    
    class MultipartBodyTest {
      @Test
      fun onePartRequired() {
        assertFailsWith<IllegalStateException> {
          MultipartBody.Builder().build()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/InterceptorTest.kt

            return original!!.contentLength()
          }
    
          override fun writeTo(sink: BufferedSink) {
            val uppercase = uppercase(sink)
            val bufferedSink = uppercase.buffer()
            original!!.writeTo(bufferedSink)
            bufferedSink.emit()
          }
        }
      }
    
      private fun uppercase(original: BufferedSink): Sink {
        return object : ForwardingSink(original) {
          override fun write(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/DuplexTest.kt

    import okhttp3.TestUtil.assumeNotWindows
    import okhttp3.internal.RecordingOkAuthenticator
    import okhttp3.internal.duplex.AsyncRequestBody
    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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.util.UUID
    import okhttp3.MediaType.Companion.toMediaType
    import okhttp3.internal.toImmutableList
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    
    /**
     * An [RFC 2387][rfc_2387]-compliant request body.
     *
     * [rfc_2387]: http://www.ietf.org/rfc/rfc2387.txt
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

    import okhttp3.internal.http.StatusLine
    import okhttp3.internal.http.promisesBody
    import okhttp3.internal.http.receiveHeaders
    import okhttp3.internal.skipAll
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ForwardingTimeout
    import okio.Sink
    import okio.Source
    import okio.Timeout
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

    import okhttp3.internal.toImmutableList
    import okhttp3.internal.ws.RealWebSocket
    import okhttp3.internal.ws.WebSocketExtensions
    import okhttp3.internal.ws.WebSocketProtocol
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.Sink
    import okio.Timeout
    import okio.buffer
    import okio.sink
    import okio.source
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  7. okhttp/src/main/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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import okhttp3.MediaType.Companion.toMediaTypeOrNull
    import okhttp3.TestUtil.repeat
    import okhttp3.testing.Flaky
    import okio.BufferedSink
    import org.junit.jupiter.api.BeforeEach
    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)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  9. okhttp/src/test/java/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.Tag
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. okhttp/src/main/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 {
      internal val lock: ReentrantLock = ReentrantLock()
    
      private val hpackBuffer: Buffer = Buffer()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
Back to top