- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Sleep (0.24 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/internal/SleepNanos.kt
* */ package mockwebserver3.internal internal fun sleepNanos(nanos: Long) { val ms = nanos / 1_000_000L val ns = nanos - (ms * 1_000_000L) if (ms > 0L || nanos > 0) { Thread.sleep(ms, ns.toInt()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 07 16:05:34 GMT 2024 - 811 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, pipe.source, metadata, 5) val future1 = executor.submit(sourceReader(relay.newSource())) val future2 = executor.submit(sourceReader(relay.newSource())) Thread.sleep(500) sink.writeUtf8("abcdefghij") Thread.sleep(500) sink.writeUtf8("klmnopqrst") sink.close() assertThat<ByteString>(future1.get()) .isEqualTo("abcdefghijklmnopqrst".encodeUtf8())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
responseBody.close() } private fun sleep(delayMillis: Int) { try { Thread.sleep(delayMillis.toLong()) } catch (e: InterruptedException) { Thread.currentThread().interrupt() } } private fun interruptLater(delayMillis: Int) { val toInterrupt = Thread.currentThread() val interruptingCow = Thread { sleep(delayMillis) toInterrupt.interrupt()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
fuzzing/fuzzingserver-test.sh
exit 1 fi which jq if [ $? != 0 ]; then echo "Run 'brew install jq'" exit 1 fi trap 'kill $(jobs -pr)' SIGINT SIGTERM EXIT set -ex wstest -m fuzzingserver -s fuzzingserver-config.json & sleep 2 # wait for wstest to start java -jar target/okhttp-tests-*-jar-with-dependencies.jar jq '.[] as $in | $in | keys[] | . + " " + $in[.].behavior' target/fuzzingserver-report/index.json > target/fuzzingserver-actual.txt
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Mar 26 02:01:32 GMT 2019 - 673 bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
responseSent.countDown() } } fun exhaustResponse() = apply { actions += { stream -> stream.responseBody.close() } } fun sleep( duration: Long, unit: TimeUnit, ) = apply { actions += { Thread.sleep(unit.toMillis(duration)) } } override fun handle(stream: Stream) { val task = serviceStreamTask(stream) results.add(task) task.run() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
} } override fun connectTcp(): ConnectResult { check(connectState == ConnectState.READY) events += "plan $id TCP connecting..." taskFaker.sleep(tcpConnectDelayNanos) if (yieldBeforeTcpConnectReturns) { taskFaker.yield() } return when { tcpConnectThrowable != null -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
assertThat(log.take()).isEqualTo("normal task running") assertThat(log).isEmpty() } @Test fun idleLatchAfterShutdown() { queue.schedule("task") { Thread.sleep(250) backend.shutdown() return@schedule -1L } assertThat(queue.idleLatch().await(500L, TimeUnit.MILLISECONDS)).isTrue() assertThat(queue.idleLatch().count).isEqualTo(0) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Jul 06 03:18:15 GMT 2018 - 3.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* java/lang/ref/FinalizationTester.java */ @Throws(Exception::class) @JvmStatic fun awaitGarbageCollection() { Runtime.getRuntime().gc() Thread.sleep(100) System.runFinalization() } @JvmStatic fun assumeNetwork() { try { InetAddress.getByName("www.google.com") } catch (uhe: UnknownHostException) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0)