- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 560 for fun (0.12 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
import okio.Buffer import okio.ByteString internal fun Dispatcher.wrap(): mockwebserver3.Dispatcher { if (this is QueueDispatcher) return this.delegate val delegate = this return object : mockwebserver3.Dispatcher() { override fun dispatch(request: mockwebserver3.RecordedRequest): mockwebserver3.MockResponse = delegate.dispatch(request.unwrap()).wrap() override fun peek(): mockwebserver3.MockResponse = delegate.peek().wrap()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 4.3K bytes - Click Count (1) -
build-logic-commons/module-identity/src/main/kotlin/gradlebuild/identity/tasks/BuildReceipt.kt
}, file ) } private fun getBuildTimestampAsString() = buildTimestamp.get().let { timestampFormat.format(it) } private fun getBuildTimestampAsIsoString() = buildTimestamp.get().let { isoTimestampFormat.format(it) } private fun Logger.logBuildVersion() { lifecycle( "Version: ${version.get()} " +Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Wed Mar 25 08:51:12 GMT 2026 - 4.1K bytes - Click Count (0) -
okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
private var serverSocket: ServerSocket? = null @BeforeEach fun setUp() { executorService = Executors.newCachedThreadPool(threadFactory("HandshakeCertificatesTest")) } @AfterEach fun tearDown() { executorService.shutdown() serverSocket?.closeQuietly() } @Test fun clientAndServer() { platform.assumeNotConscrypt() platform.assumeNotBouncyCastle()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 08:16:15 GMT 2026 - 7.5K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt
message.startsWith("Using PSK to derive early secret") -> Type.Handshake else -> Type.Unknown } override fun toString(): String = if (param != null) { message + "\n" + param } else { message } } private fun quietDebug(message: JsseDebugMessage) { if (message.message.startsWith("Ignore")) { return } when (message.type) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 2.8K bytes - Click Count (0) -
android-test-app/src/main/kotlin/okhttp/android/testapp/TestApplication.kt
import okhttp3.OkHttp class TestApplication : Application() { override fun onCreate() { super.onCreate() if (isSecondaryProcess()) { OkHttp.initialize(applicationContext) } } private fun isSecondaryProcess(): Boolean = getProcess() != packageName @SuppressLint("DiscouragedPrivateApi") private fun getProcess(): String? = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.P) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Aug 19 08:10:39 GMT 2025 - 1.3K bytes - Click Count (0) -
build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/FixProjectHealthTask.kt
import java.io.File @DisableCachingByDefault abstract class FixProjectHealthTask : DefaultTask() { private val errorLogFile = File("gradle-project-health.log") @TaskAction fun fixProjectHealth() { if (!errorLogFile.exists()) { println("Error log not found! Run the projectHealth check first and redirect output.") return }
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon Mar 03 06:57:08 GMT 2025 - 6.2K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
*/ private val routePlanner = FakeRoutePlanner(taskFaker = taskFaker) private val finder = FastFallbackExchangeFinder(routePlanner, taskRunner) @AfterEach fun tearDown() { taskFaker.close() routePlanner.close() } @Test fun takeConnectedConnection() { val plan0 = routePlanner.addPlan() plan0.connectState = TLS_CONNECTED taskRunner.newQueue().execute("connect") {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 20.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/BufferedSocket.kt
override val sink: BufferedSink } fun JavaNetSocket.asBufferedSocket(): BufferedSocket = asOkioSocket().asBufferedSocket() fun OkioSocket.asBufferedSocket(): BufferedSocket = object : BufferedSocket { private val delegate = this@asBufferedSocket override val source = delegate.source.buffer() override val sink = delegate.sink.buffer() override fun cancel() { delegate.cancel() }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 1.3K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/AbstractAcceptedApiChangesMaintenanceTask.kt
protected fun sortChanges(originalChanges: List<AcceptedApiChange>) = originalChanges.toMutableList().sortedBy { it.type + '#' + it.member } @VisibleForTesting data class AcceptedApiChange( val type: String?, val member: String?, val acceptation: String?, val changes: List<String>? ) { override fun toString(): String = "Type: '$type', Member: '$member'"Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jun 04 14:00:46 GMT 2024 - 2.9K bytes - Click Count (0) -
samples/guide/src/test/kotlin/okhttp3/AllMainsTest.kt
import org.junit.jupiter.api.Tag import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource private val prefix = if (File("samples").exists()) "" else "../../" private fun mainFiles(): List<File> { val directories = listOf( "$prefix/samples/guide/src/main/java/okhttp3/guide", "$prefix/samples/guide/src/main/java/okhttp3/recipes",
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 2.8K bytes - Click Count (0)