- Sort Score
- Result 10 results
- Languages All
Results 1581 - 1590 of 4,785 for New (0.02 sec)
-
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} public void testListenersNotifiedOnError() throws Exception { CountDownLatch successLatch = new CountDownLatch(1); CountDownLatch listenerLatch = new CountDownLatch(1); ExecutorService exec = Executors.newCachedThreadPool(); future.addListener(listenerLatch::countDown, exec); new Thread( () -> { assertThrows(CancellationException.class, future::get);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/warm-backend-s3.go
return nil, errors.New("AWS Role cannot be activated with static credentials or the web identity token file") case conf.Bucket == "": return nil, errors.New("no bucket name was provided") } // Credentials initialization var creds *credentials.Credentials switch { case conf.AWSRole: creds = credentials.New(&credentials.IAM{ Client: &http.Client{ Transport: NewHTTPTransport(),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java
static final RuntimeException RUNTIME_EXCEPTION = new RuntimeException(); static final OtherThrowable OTHER_THROWABLE = new OtherThrowable(); static final Future<String> FAILED_FUTURE_OTHER_THROWABLE = immediateFailedFuture(OTHER_THROWABLE); static final Error ERROR = new Error("mymessage"); static final Future<String> FAILED_FUTURE_ERROR = immediateFailedFuture(ERROR); static final Future<String> RUNTIME_EXCEPTION_FUTURE =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 13:46:56 UTC 2023 - 6.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/http/Handler.java
protected int getDefaultPort() { return DEFAULT_HTTP_PORT; } protected URLConnection openConnection(URL url) throws IOException { url = new URL(url, url.toExternalForm(), getDefaultStreamHandler(url.getProtocol())); return new NtlmHttpURLConnection((HttpURLConnection) url.openConnection()); } private static URLStreamHandler getDefaultStreamHandler(String protocol)
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 6.1K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/TypeMetaData.java
} TypeMetaData rawType = new TypeMetaData(name); rawType.arrayDimensions = arrayDimensions; if (varargs) { rawType.arrayDimensions++; } return rawType; } public String getSignature() { final StringBuilder builder = new StringBuilder(); visitSignature(new SignatureVisitor() { @Override
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 6.1K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/math/IntMathBenchmark.java
*/ public class IntMathBenchmark { private static int[] exponent = new int[ARRAY_SIZE]; private static int[] factorial = new int[ARRAY_SIZE]; private static int[] binomial = new int[ARRAY_SIZE]; private static final int[] positive = new int[ARRAY_SIZE]; private static final int[] nonnegative = new int[ARRAY_SIZE]; private static final int[] ints = new int[ARRAY_SIZE]; @BeforeExperiment void setUp() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
checkNotNull(unit); final Thread interruptee = Thread.currentThread(); new Thread( new Runnable() { @Override public void run() { try { unit.sleep(time); } catch (InterruptedException wontHappen) { throw new AssertionError(wontHappen); } interruptee.interrupt();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbWatchHandleImpl.java
throw new SmbUnsupportedOperationException("Not supported without CAP_NT_SMBS"); } /* * NtTrans Notify Change Request / Response */ req = new NtTransNotifyChange(th.getConfig(), this.handle.getFid(), this.filter, this.recursive); resp = new NtTransNotifyChangeResponse(th.getConfig()); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/HMACT64.java
private static final byte IPAD = (byte) 0x36; private static final byte OPAD = (byte) 0x5c; private MessageDigest md5; private byte[] ipad = new byte[BLOCK_LENGTH]; private byte[] opad = new byte[BLOCK_LENGTH]; /** * Creates an HMACT64 instance which uses the given secret key material. * * @param key The key material to use in hashing. */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 3.4K bytes - Viewed (0)