- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 737 for vals (0.01 sec)
-
container-tests/src/test/java/okhttp3/containers/BasicMockServerTest.kt
apply { val keyStoreFactory = KeyStoreFactory(Configuration.configuration(), MockServerLogger()) val socketFactory = keyStoreFactory.sslContext().socketFactory val trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm()) trustManagerFactory.init(keyStoreFactory.loadOrCreateKeyStore())
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.4K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt
@Suppress("ktlint:standard:max-line-length") class LoggingEventListenerTest { @RegisterExtension val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() @StartStop private val server = MockWebServer() private val handshakeCertificates = platform.localhostHandshakeCertificates() private val logRecorder = HttpLoggingInterceptorTest.LogRecorder( prefix = Regex("""\[\d+ ms] """),
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 10.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
duration: Int, timeUnit: TimeUnit, ): Boolean { val nowNs = System.nanoTime() val originalDurationNs = if (timeout().hasDeadline()) { timeout().deadlineNanoTime() - nowNs } else { Long.MAX_VALUE } timeout().deadlineNanoTime(nowNs + minOf(originalDurationNs, timeUnit.toNanos(duration.toLong()))) return try { val skipBuffer = Buffer() while (read(skipBuffer, 8192) != -1L) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 10.2K bytes - Viewed (1) -
.teamcity/src/main/kotlin/projects/CheckProject.kt
var prevStage: Stage? = null val previousPerformanceTestPasses: MutableList<PerformanceTestsPass> = mutableListOf() val previousCrossVersionTests: MutableList<BaseGradleBuildType> = mutableListOf() model.stages.forEach { stage -> if (isSecurityFork() && stage.stageName > StageName.READY_FOR_RELEASE) { return@forEach } val stageProject = StageProject(
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Wed Feb 12 09:12:03 UTC 2025 - 3.9K bytes - Viewed (1) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/Iana.kt
import okio.IOException /** Example: "0x00,0x08",TLS_RSA_EXPORT_WITH_DES40_CBC_SHA,Y,N,[RFC4346] */ val IANA_CSV_PATTERN = "\"0x(\\w\\w),0x(\\w\\w)\",(\\w+).*".toRegex() fun parseIanaCsvRow(s: String): SuiteId? { if (s.contains("Reserved") || s.contains("Unassigned")) return null val matcher = IANA_CSV_PATTERN.matchEntire(s) ?: return null val id = (matcher.groupValues[1] + matcher.groupValues[2]).decodeHex()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2K bytes - Viewed (0) -
cmd/peer-rest-server.go
func (s *peerRESTServer) StartProfilingHandler(w http.ResponseWriter, r *http.Request) { if !s.IsValid(w, r) { s.writeErrorResponse(w, errors.New("Invalid request")) return } vars := mux.Vars(r) profiles := strings.Split(vars[peerRESTProfiler], ",") if len(profiles) == 0 { s.writeErrorResponse(w, errors.New("profiler name is missing")) return } globalProfilerMu.Lock() defer globalProfilerMu.Unlock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 53.4K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
@Tag("Slowish") class EventSourceHttpTest { @RegisterExtension val platform = PlatformRule() @StartStop private val server = MockWebServer() @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val eventListener = RecordingEventListener() private val listener = EventSourceRecorder() private var client = clientTestRule .newClientBuilder()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:47:47 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpStatusCodes.kt
const val HTTP_CONTINUE = 100 /** `101 Switching Protocols` (HTTP/1.1 - RFC 9110) */ const val HTTP_SWITCHING_PROTOCOLS = 101 /** `102 Processing` (WebDAV - RFC 2518) */ const val HTTP_PROCESSING = 102 /** `103 Early Hints (Early Hints - RFC 8297)` */ const val HTTP_EARLY_HINTS = 103 /** `307 Temporary Redirect` (HTTP/1.1 - RFC 7231) */ const val HTTP_TEMP_REDIRECT = 307
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 2K bytes - Viewed (0) -
mockwebserver-junit5/src/main/kotlin/mockwebserver3/junit5/internal/StartStopExtension.kt
override fun beforeAll(context: ExtensionContext) { val store = context.getStore(Namespace.create(StartStop::class.java)) val staticFields = findAnnotatedFields( context.requiredTestClass, StartStop::class.java, ) { Modifier.isStatic(it.modifiers) } for (field in staticFields) { field.setAccessible(true) val server = field.get(null) as? MockWebServer ?: continue
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jun 19 11:44:16 UTC 2025 - 2.3K bytes - Viewed (0) -
settings.gradle.kts
include(":samples:unixdomainsockets") include(":container-tests") project(":okhttp-logging-interceptor").name = "logging-interceptor" val androidHome = System.getenv("ANDROID_HOME") val localProperties = Properties().apply { val file = File("local.properties") if (file.exists()) { load(file.inputStream()) } } val sdkDir = localProperties.getProperty("sdk.dir") if (androidHome != null || sdkDir != null) { include(":android-test")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jul 19 13:41:00 UTC 2025 - 1.9K bytes - Viewed (0)