Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 2,682 for latch (0.09 seconds)

  1. 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)
  2. 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)
  3. 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 0x0040
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top