- Sort Score
- Result 10 results
- Languages All
Results 1891 - 1900 of 2,330 for junit (0.04 sec)
-
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
@ParametricNullness final V blockingGet(long timeout, TimeUnit unit) throws InterruptedException, TimeoutException, ExecutionException { // NOTE: if timeout < 0, remainingNanos will be < 0 and we will fall into the while(true) loop // at the bottom and throw a timeoutexception. long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit. long remainingNanos = timeoutNanos;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/fscc/SmbInfoAllocation.java
/** * Represents the SMB_INFO_ALLOCATION information level used in SMB transaction requests. * This structure provides allocation information for a file system including total units, * free units, sectors per allocation unit, and bytes per sector. */ public class SmbInfoAllocation implements AllocInfo { /** * Default constructor for SMB allocation information. */ public SmbInfoAllocation() {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.9K bytes - Viewed (0) -
CONTRIBUTING.md
- Check if your changes are consistent with the [guidelines](#general-guidelines-and-philosophy-for-contribution). - Changes are consistent with the [Coding Style](#c-coding-style). - Run the [unit tests](#running-unit-tests). ## How to become a contributor and submit your own code Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Sat Jan 11 04:47:59 UTC 2025 - 15.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
SocketPolicy.UPGRADE_TO_SSL_AT_END -> result.inTunnel() SocketPolicy.SHUTDOWN_SERVER_AFTER_RESPONSE -> result.shutdownServer(true) SocketPolicy.KEEP_OPEN -> Unit SocketPolicy.DISCONNECT_AT_END -> result.onResponseEnd(ShutdownConnection) SocketPolicy.DISCONNECT_AT_START -> result.onRequestStart(CloseSocket())
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 03 13:16:34 UTC 2025 - 4.1K bytes - Viewed (1) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
name = "NULL", tagClass = DerHeader.TAG_CLASS_UNIVERSAL, tag = 5L, codec = object : BasicDerAdapter.Codec<Unit?> { override fun decode(reader: DerReader): Unit? = null override fun encode( writer: DerWriter, value: Unit?, ) { } }, ) val OBJECT_IDENTIFIER = BasicDerAdapter(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 15K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ImmediateFuture.java
@Override @ParametricNullness public V get() { return value; } @Override @ParametricNullness public V get(long timeout, TimeUnit unit) throws ExecutionException { checkNotNull(unit); return get(); } @Override public boolean isCancelled() { return false; } @Override public boolean isDone() { return true; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 3.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/DirectExecutorService.java
public boolean isTerminated() { synchronized (lock) { return shutdown && runningTasks == 0; } } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { long nanos = unit.toNanos(timeout); synchronized (lock) { while (true) { if (shutdown && runningTasks == 0) { return true; } else if (nanos <= 0) { return false;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Apr 12 15:07:59 UTC 2025 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
Service.super.awaitRunning(timeout); } @Override public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException { if (monitor.enterWhenUninterruptibly(hasReachedRunning, timeout, unit)) { try { checkCurrentState(RUNNING); } finally { monitor.leave(); } } else {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0)