- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,286 for after (0.17 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java
for (int i = 0; i < ITERATIONS; i++) { long before = map.get(key); long result = map.addAndGet(key, addend); long after = map.get(key); assertEquals(before + addend, after); assertEquals(after, result); addend = after; } assertEquals(1, map.size()); assertTrue(!map.isEmpty()); assertTrue(map.containsKey(key)); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 17.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
assertThat(testLogHandler.takeAll()).containsExactly( "FINE: Q10000 scheduled after 100 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 run again after 50 µs: task", "FINE: Q10000 finished run in 0 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 run again after 150 µs: task", "FINE: Q10000 finished run in 0 µs: task",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
CountingRunnable after = new CountingRunnable(); future.addListener(before, directExecutor()); future.setFuture(delegate); future.addListener(inBetween, directExecutor()); delegate.set(1); future.addListener(after, directExecutor()); before.assertRun(); inBetween.assertRun(); after.assertRun(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
docs/bucket/replication/setup_2site_existing_replication.sh
sitea_out=$(cat /tmp/sitea_dirs.txt) siteb_out=$(cat /tmp/siteb_dirs.txt) if [ $sitea_count -ne 0 ]; then echo "BUG: expected no 'directory objects' left after deletion: ${sitea_out}" exit 1 fi if [ $siteb_count -ne 0 ]; then echo "BUG: expected no 'directory objects' left after deletion: ${siteb_out}" exit 1 fi
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 5.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
sealed interface SocketPolicy { /** * Shutdown [MockWebServer] after writing response. */ object ShutdownServerAfterResponse : SocketPolicy /** * Keep the socket open after the response. This is the default HTTP/1.1 behavior. */ object KeepOpen : SocketPolicy /** * Close the socket after the response. This is the default HTTP/1.0 behavior. For HTTP/2
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java
for (int i = 0; i < ITERATIONS; i++) { long before = map.get(key); long result = map.addAndGet(key, addend); long after = map.get(key); assertEquals(before + addend, after); assertEquals(after, result); addend = after; } assertEquals(1, map.size()); assertTrue(!map.isEmpty()); assertTrue(map.containsKey(key)); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 17.4K bytes - Viewed (0) -
tests/test_tutorial/test_extra_data_types/test_tutorial001.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Fri Apr 19 00:11:40 GMT 2024 - 6.8K bytes - Viewed (0) -
.github/actions/people/app/main.py
if response.status_code != 200: logging.error( f"Response was not 200, after: {after}, category_id: {category_id}" ) logging.error(response.text) raise RuntimeError(response.text) data = response.json() if "errors" in data: logging.error(f"Errors in response, after: {after}, category_id: {category_id}") logging.error(data["errors"])
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Mar 26 17:38:21 GMT 2024 - 19.2K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
CountingRunnable after = new CountingRunnable(); future.addListener(before, directExecutor()); future.setFuture(delegate); future.addListener(inBetween, directExecutor()); delegate.set(1); future.addListener(after, directExecutor()); before.assertRun(); inBetween.assertRun(); after.assertRun(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/batch-expire_gen_test.go
} left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBatchJobExpire(b *testing.B) { v := BatchJobExpire{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 6.9K bytes - Viewed (0)