- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 55 for BufferedSink (0.06 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)