- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 2,682 for latch (0.04 seconds)
-
android/guava-tests/test/com/google/common/primitives/ReflectionFreeAssertThrows.java
+ " map in that class."); } Object result; try { result = supplier.get(); } catch (Throwable t) { if (predicate.apply(t)) { // We are careful to set up INSTANCE_OF to match each Predicate to its target Class. @SuppressWarnings("unchecked") T caught = (T) t; return caught; } throw new AssertionError(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/net/ReflectionFreeAssertThrows.java
+ " map in that class."); } Object result; try { result = supplier.get(); } catch (Throwable t) { if (predicate.apply(t)) { // We are careful to set up INSTANCE_OF to match each Predicate to its target Class. @SuppressWarnings("unchecked") T caught = (T) t; return caught; } throw new AssertionError(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/com/SmbComNTCreateAndXTest.java
// Use reflection to read the private field createDisposition int actual = (int) getPrivateField(req, "createDisposition"); assertEquals(expected, actual, "createDisposition should match"); } } @Test @DisplayName("CreateOptions default padding") void createOptionsAddedWhenLow() { // createOptions less than 0x0001 (i.e., 0) should be padded with 0x0040Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.6K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteStreams.java
try { return input.readByte(); } catch (EOFException e) { throw new IllegalStateException(e); } catch (IOException impossible) { throw new AssertionError(impossible); } } @Override public int readUnsignedByte() { try { return input.readUnsignedByte(); } catch (IOException e) { throw new IllegalStateException(e); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 31.1K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbFileInputStreamTest.java
Field offField = Smb2ReadRequest.class.getDeclaredField("offset"); offField.setAccessible(true); long offVal = offField.getLong(req); assertEquals(2L, offVal, "Request offset should match skipped bytes"); } @Test @DisplayName("read(byte[]) delegates to read(byte[],off,len)") void readArrayDelegates() throws Exception { SmbFileInputStream in = newStream();
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 12.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
if (address.url.host == this .route() .address.url.host ) { return true // This connection is a perfect match. } // At this point we don't have a hostname match. But we still be able to carry the request if // our connection coalescing requirements are met. See also: // https://hpbn.co/optimizing-application-delivery/#eliminate-domain-sharding
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt
var certificatePem: String? = null var pkcs8Base64: String? = null for (match in PEM_REGEX.findAll(certificateAndPrivateKeyPem)) { when (val label = match.groups[1]!!.value) { "CERTIFICATE" -> { require(certificatePem == null) { "string includes multiple certificates" } certificatePem = match.groups[0]!!.value // Keep --BEGIN-- and --END-- for certificates. }Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 21.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/ReflectionFreeAssertThrows.java
+ " map in that class."); } Object result; try { result = supplier.get(); } catch (Throwable t) { if (predicate.apply(t)) { // We are careful to set up INSTANCE_OF to match each Predicate to its target Class. @SuppressWarnings("unchecked") T caught = (T) t; return caught; } throw new AssertionError(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6.2K bytes - Click Count (0) -
guava-testlib/src/com/google/common/collect/testing/ReflectionFreeAssertThrows.java
+ " map in that class."); } Object result; try { result = supplier.get(); } catch (Throwable t) { if (predicate.apply(t)) { // We are careful to set up INSTANCE_OF to match each Predicate to its target Class. @SuppressWarnings("unchecked") T caught = (T) t; return caught; } throw new AssertionError(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java
return stemmerOverrideService.getStemmerOverrideFile(form.dictId).map(file -> { try (InputStream inputStream = form.stemmerOverrideFile.getInputStream()) { file.update(inputStream); } catch (final IOException e) { logger.warn("Failed to process a request.", e); throwValidationError(messages -> messages.addErrorsFailedToUploadStemmeroverrideFile(GLOBAL),
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 23.5K bytes - Click Count (0)