- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 541 for conceal (0.2 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
this, IllegalStateException("Invalid content-type: ${body.contentType()}"), response, ) return } // This is a long-lived response. Cancel full-call timeouts. call?.timeout()?.cancel() // Replace the body with a stripped one so the callbacks can't see real data. val response = response.stripBody() val reader = ServerSentEventReader(body.source(), this)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/erasure-object_test.go
"runtime" "strconv" "testing" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/config/storageclass" ) func TestRepeatPutObjectPart(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() var objLayer ObjectLayer var disks []string var err error var opts ObjectOptions objLayer, disks, err = prepareErasure16(ctx) if err != nil { t.Fatal(err) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FailedPlan.kt
override val isReady = false override fun connectTcp() = result override fun connectTlsEtc() = result override fun handleSuccess() = error("unexpected call") override fun cancel() = error("unexpected cancel") override fun retry() = error("unexpected retry")
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} private fun cancelLater( call: Call, delayMillis: Int, ): CountDownLatch { val latch = CountDownLatch(1) Thread { sleep(delayMillis) if (cancelMode == CANCEL) { call.cancel() } else { threadToCancel!!.interrupt() } latch.countDown() }.apply { start() } return latch } companion object {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/primitives/LongArrayAsListTest.java
Long[] prefix = {Long.MIN_VALUE, Long.MAX_VALUE}; Long[] suffix = {(long) 86, (long) 99}; Long[] all = concat(concat(prefix, elements), suffix); return asList(all).subList(2, elements.length + 2); } } private static Long[] concat(Long[] left, Long[] right) { Long[] result = new Long[left.length + right.length]; System.arraycopy(left, 0, result, 0, left.length);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Jun 01 09:32:35 GMT 2023 - 5.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} catch (TimeoutException expected) { } finally { latch.countDown(); } } /** * Tests that a canceled future throws a cancellation exception. * * <p>This method checks the cancel, isCancelled, and isDone methods. */ public void testCanceledFutureThrowsCancellation() throws Exception { assertFalse(future.isDone()); assertFalse(future.isCancelled());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} public void testCancelled() throws Exception { TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2)); assertFalse(task.isDone()); task.cancel(false); assertTrue(task.isDone()); assertTrue(task.isCancelled()); assertFalse(task.wasInterrupted()); try { getDone(task); fail(); } catch (CancellationException expected) { }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
okhttp-coroutines/README.md
that by default Kotlin's Dispatchers are not used. Cancellation if implemented sensibly in both directions. Cancelling a coroutine scope, will cancel the call. Cancelling a call, will throw a CancellationException
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Nov 09 15:47:27 GMT 2023 - 609 bytes - Viewed (0) -
guava-tests/test/com/google/common/primitives/IntArrayAsListTest.java
Integer[] prefix = {Integer.MIN_VALUE, Integer.MAX_VALUE}; Integer[] suffix = {(int) 86, (int) 99}; Integer[] all = concat(concat(prefix, elements), suffix); return asList(all).subList(2, elements.length + 2); } } private static Integer[] concat(Integer[] left, Integer[] right) { Integer[] result = new Integer[left.length + right.length]; System.arraycopy(left, 0, result, 0, left.length);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Jun 01 09:32:35 GMT 2023 - 5.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/primitives/ByteArrayAsListTest.java
Byte[] prefix = {Byte.MIN_VALUE, Byte.MAX_VALUE}; Byte[] suffix = {(byte) 86, (byte) 99}; Byte[] all = concat(concat(prefix, elements), suffix); return asList(all).subList(2, elements.length + 2); } } private static Byte[] concat(Byte[] left, Byte[] right) { Byte[] result = new Byte[left.length + right.length]; System.arraycopy(left, 0, result, 0, left.length);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Jun 01 09:32:35 GMT 2023 - 5.5K bytes - Viewed (0)